Skip¶

Observable.skip(count)¶

Bypasses a specified number of elements in an observable sequence and then returns the remaining elements.

Keyword arguments: count – The number of elements to skip before returning the remaining

elements.

Returns an observable sequence that contains the elements that occur after the specified index in the input sequence.

Observable.skip_with_time(duration, scheduler=None)¶

Skips elements for the specified duration from the start of the observable source sequence, using the specified scheduler to run timers.

Example: 1 - res = source.skip_with_time(5000, [optional scheduler])

Description: Specifying a zero value for duration doesn’t guarantee no elements will be dropped from the start of the source sequence. This is a side-effect of the asynchrony introduced by the scheduler, where the action that causes callbacks from the source sequence to be forwarded may not execute immediately, despite the zero due time.

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

Keyword arguments: duration – {Number} Duration for skipping elements from the start of

the sequence.

scheduler – {Scheduler} Scheduler to run the timer on. If not

specified, defaults to Rx.Scheduler.timeout.

Returns n observable {Observable} sequence with the elements skipped during the specified duration from the start of the source sequence.