Skip to content
This repository has been archived by the owner on Apr 20, 2018. It is now read-only.

Latest commit

 

History

History
65 lines (52 loc) · 2.67 KB

takelastwithtime.md

File metadata and controls

65 lines (52 loc) · 2.67 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: