Rx.Observable.prototype.takeLastWithTime(duration, [timeScheduler], [loopScheduler])
Returns elements within the specified duration from the end of the observable source sequence, using the specified schedulers to run timers and to drain the collected elements.
Arguments
duration
(Number
): Duration for taking elements from the end of the sequence.[timeScheduler=Rx.Scheduler.timeout]
(Scheduler
): Scheduler to run the timer on. If not specified, defaults to timeout scheduler.[loopScheduler=Rx.Scheduler.currentThread]
(Scheduler
): Scheduler to drain the collected elements. If not specified, defaults to current thread scheduler.
Returns
(Observable
): An observable sequence with the elements taken during the specified duration from the end of the source sequence.