rx/core/observablebase.py
def take_with_time(self, duration: Union[timedelta, int]) -> 'ObservableBase':
        """Takes elements for the specified duration from the start of
        the observable source sequence.

        Example:
        res = source.take_with_time(5000)

        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 -- Duration for taking elements from the start of the
            sequence.

        Returns an observable sequence with the elements taken during
        the specified duration from the start of the source sequence.
        """
        from ..operators.observable.takewithtime import take_with_time
        return take_with_time(self, duration)
Takes elements for the specified duration from the start of
        the observable source sequence.

        Example:
        res = source.take_with_time(5000)

        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 -- Duration for taking elements from the start of the
            sequence.

        Returns an observable sequence with the elements taken during
        the specified duration from the start of the source sequence.
        
Takes elements for the specified duration from the start of
the observable source sequence.
Takes elements for the specified duration from the start of the observable source sequence .
def take_with_time(self, duration: Union[timedelta, int]) -> 'ObservableBase':
        from ..operators.observable.takewithtime import take_with_time
        return take_with_time(self, duration)
def take_with_time ( self , duration : Union [ timedelta , int ] ) -> 'ObservableBase' : from . . operators . observable . takewithtime import take_with_time return take_with_time ( self , duration )
Takes elements for the specified duration from the start of
the observable source sequence.
Takes elements for the specified duration from the start of the observable source sequence .
"""Takes elements for the specified duration from the start of
        the observable source sequence.

        Example:
        res = source.take_with_time(5000)

        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 -- Duration for taking elements from the start of the
            sequence.

        Returns an observable sequence with the elements taken during
        the specified duration from the start of the source sequence.
        """
self
duration
Union[timedelta, int]
examples
None