Skip last¶

Observable.skip_last(count)¶

Bypasses a specified number of elements at the end of an observable sequence.

Description: This operator accumulates a queue with a length enough to store the first count elements. As more elements are received, elements are taken from the front of the queue and produced on the result sequence. This causes elements to be delayed.

Keyword arguments count – Number of elements to bypass at the end of the source sequence.

Returns an observable {Observable} sequence containing the source sequence elements except for the bypassed ones at the end.

Observable.skip_last_with_time(duration, scheduler)¶

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

1 - res = source.skip_last_with_time(5000) 2 - res = source.skip_last_with_time(5000, scheduler)

Description: This operator accumulates a queue with a length enough to store elements received during the initial duration window. As more elements are received, elements older than the specified duration are taken from the queue and produced on the result sequence. This causes elements to be delayed with duration.

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

sequence.

scheduler – {Scheduler} [Optional] Scheduler to run the timer on. If

not specified, defaults to Rx.Scheduler.timeout

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