Controlled

See also

• Official ReactiveX documentation: Controlled

Observable.controlled(enable_queue=True, scheduler=None)

Attach a controller to the observable sequence

Attach a controller to the observable sequence with the ability to queue.

Example: source = rx.Observable.interval(100).controlled() source.request(3) # Reads 3 values

Keyword arguments: :param bool enable_queue: truthy value to determine if values should

be queued pending the next request

Parameters:scheduler (Scheduler) – determines how the requests will be scheduled Returns:The observable sequence which only propagates values on request. Return type:Observable