skipuntilwithtime.md

This is RxJS v 4. Find the latest version here

Rx.Observable.prototype.skipUntilWithTime(startTime, [scheduler])

Ⓢ

Skips elements from the observable source sequence until the specified start time, using the specified scheduler to run timers.

Errors produced by the source sequence are always forwarded to the result sequence, even if the error occurs before the start time.

Arguments

1. startTime (Date | Number): Time to start taking elements from the source sequence. If this value is less than or equal to current time, no elements will be skipped.
2. [scheduler = Rx.Scheduler.timeout] (Scheduler): Scheduler to run the timer on. If not specified, defaults to Rx.Scheduler.timeout.

Returns

(Observable): An observable sequence with the elements skipped until the specified start time.

Example

// Using relative time
var source = Rx.Observable.timer(0, 1000)
    .skipUntilWithTime(5000);

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

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

Location

File:

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

Dist:

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

Prerequisites:

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

NPM Packages:

• rx

NuGet Packages:

• RxJS-All
• RxJS-Time

Unit Tests:

• /tests/observable/skipuntilwithtime.js