This is RxJS v 4. Find the latest version here

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:

• /src/core/linq/observable/takelastwithtime.js

Dist:

• rx.all.js
• rx.all.compat.js
• rx.time.js
• rx.lite.js
• rx.lite.compat.js

Prerequisites:

• If using rx.time.js
  • rx.js | rx.compat.js

NPM Packages:

• rx

NuGet Packages:

• RxJS-All
• RxJS-Time
• RxJS-Lite

Unit Tests:

• /tests/observable/skipuntilwithtime.js