Skip to content

Latest commit

 

History

History
64 lines (51 loc) · 2.58 KB

takelastwithtime.md

File metadata and controls

64 lines (51 loc) · 2.58 KB

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

  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.

Returns

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

Example

var source = Rx.Observable.timer(0, 1000)
    .take(10)
    .takeLastWithTime(5000);

var subscription = source.subscribe(
    function (x) {
        console.log('Next: ' + x);
    },
    function (err) {
        console.log('Error: ' + err);
    },
    function () {
        console.log('Completed');
    });

// => Next: 5
// => Next: 6
// => Next: 7
// => Next: 8
// => Next: 9
// => Completed

Location

File:

Dist:

Prerequisites:

NPM Packages:

NuGet Packages:

Unit Tests: