Take until with time¶

See also

Observable.take_until_with_time(end_time, scheduler=None)¶

Takes elements for the specified duration until the specified end time, using the specified scheduler to run timers.

Examples: 1 - res = source.take_until_with_time(dt, [optional scheduler]) 2 - res = source.take_until_with_time(5000, [optional scheduler])

Keyword Arguments: end_time – {Number | Date} Time to stop taking elements from the source

sequence. If this value is less than or equal to Date(), the result stream will complete immediately.

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

Returns an observable {Observable} sequence with the elements taken until the specified end time.