rx/core/observablebase.py
def controlled(self, enable_queue: bool = 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

        Args:
            enable_queue: truthy value to determine if values should
                be queued pending the next request
            scheduler: determines how the requests will be scheduled

        Returns:
            The observable sequence which only propagates values on
            request.
        """

        from ..backpressure.observableextensions import controlled
        return controlled(self, enable_queue, scheduler)
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

        Args:
            enable_queue: truthy value to determine if values should
                be queued pending the next request
            scheduler: determines how the requests will be scheduled

        Returns:
            The observable sequence which only propagates values on
            request.
        
Attach a controller to the observable sequence.
Attach a controller to the observable sequence with the ability
to queue.
Attach a controller to the observable sequence . Attach a controller to the observable sequence with the ability to queue .
def controlled(self, enable_queue: bool = True, scheduler=None):
        from ..backpressure.observableextensions import controlled
        return controlled(self, enable_queue, scheduler)
def controlled ( self , enable_queue : bool = True , scheduler = None ) : from . . backpressure . observableextensions import controlled return controlled ( self , enable_queue , scheduler )
Attach a controller to the observable sequence.
Attach a controller to the observable sequence .
"""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

        Args:
            enable_queue: truthy value to determine if values should
                be queued pending the next request
            scheduler: determines how the requests will be scheduled

        Returns:
            The observable sequence which only propagates values on
            request.
        """
The observable sequence which only propagates values on
request.
The observable sequence which only propagates values on request .
self
enable_queue
bool
truthy value to determine if values should
be queued pending the next request
truthy value to determine if values should be queued pending the next request
scheduler
determines how the requests will be scheduled
determines how the requests will be scheduled
examples
>>> source = rx.Observable.interval(100).controlled()
>>> source.request(3) # Reads 3 values
>>> source = rx . Observable . interval ( 100 ) . controlled () >>> source . request ( 3 ) # Reads 3 values