rx/core/observablebase.py
def take_last_with_time(self, duration) -> 'ObservableBase':
        """Returns elements within the specified duration from the end of the
        observable source sequence.

        Example:
        res = source.take_last_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 -- {Number} Duration for taking elements from the end of the
            sequence.

        Returns an observable sequence with the elements taken during
        the specified duration from the end of the source sequence.
        """
        from ..operators.observable.takelastwithtime import take_last_with_time
        return take_last_with_time(self, duration)
Returns elements within the specified duration from the end of the
        observable source sequence.

        Example:
        res = source.take_last_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 -- {Number} Duration for taking elements from the end of the
            sequence.

        Returns an observable sequence with the elements taken during
        the specified duration from the end of the source sequence.
        
Returns elements within the specified duration from the end of the
observable source sequence.
Returns elements within the specified duration from the end of the observable source sequence .
def take_last_with_time(self, duration) -> 'ObservableBase':
        from ..operators.observable.takelastwithtime import take_last_with_time
        return take_last_with_time(self, duration)
def take_last_with_time ( self , duration ) -> 'ObservableBase' : from . . operators . observable . takelastwithtime import take_last_with_time return take_last_with_time ( self , duration )
Returns elements within the specified duration from the end of the
observable source sequence.
Returns elements within the specified duration from the end of the observable source sequence .
"""Returns elements within the specified duration from the end of the
        observable source sequence.

        Example:
        res = source.take_last_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 -- {Number} Duration for taking elements from the end of the
            sequence.

        Returns an observable sequence with the elements taken during
        the specified duration from the end of the source sequence.
        """
self
duration
examples
None