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.

参数

1. duration (Number): Duration for taking elements from the end of the sequence.
2. [timeScheduler=Rx.Scheduler.timeout] (Scheduler): Scheduler to run the timer on. If not specified, defaults to timeout scheduler.
3. [loopScheduler=Rx.Scheduler.currentThread] (Scheduler): Scheduler to drain the collected elements. If not specified, defaults to current thread scheduler.

返回值

(Observable): An observable sequence with the elements taken during the specified duration from the end of the source sequence.

例