rx/core/observablebase.py
def take_last_buffer(self, count) -> 'ObservableBase':
        """Returns an array with the specified number of contiguous
        elements from the end of an observable sequence.

        Example:
        res = source.take_last(5)

        Description:
        This operator accumulates a buffer with a length enough to store
        elements count elements. Upon completion of the source sequence,
        this buffer is drained on the result sequence. This causes the
        elements to be delayed.

        Keyword arguments:
        count -- Number of elements to take from the end of the source
            sequence.

        Returns an observable sequence containing a single list with the
        specified number of elements from the end of the source
        sequence.
        """
        from ..operators.observable.takelastbuffer import take_last_buffer
        return take_last_buffer(self, count)
Returns an array with the specified number of contiguous
        elements from the end of an observable sequence.

        Example:
        res = source.take_last(5)

        Description:
        This operator accumulates a buffer with a length enough to store
        elements count elements. Upon completion of the source sequence,
        this buffer is drained on the result sequence. This causes the
        elements to be delayed.

        Keyword arguments:
        count -- Number of elements to take from the end of the source
            sequence.

        Returns an observable sequence containing a single list with the
        specified number of elements from the end of the source
        sequence.
        
Returns an array with the specified number of contiguous
elements from the end of an observable sequence.
Returns an array with the specified number of contiguous elements from the end of an observable sequence .
def take_last_buffer(self, count) -> 'ObservableBase':
        from ..operators.observable.takelastbuffer import take_last_buffer
        return take_last_buffer(self, count)
def take_last_buffer ( self , count ) -> 'ObservableBase' : from . . operators . observable . takelastbuffer import take_last_buffer return take_last_buffer ( self , count )
Returns an array with the specified number of contiguous
elements from the end of an observable sequence.
Returns an array with the specified number of contiguous elements from the end of an observable sequence .
"""Returns an array with the specified number of contiguous
        elements from the end of an observable sequence.

        Example:
        res = source.take_last(5)

        Description:
        This operator accumulates a buffer with a length enough to store
        elements count elements. Upon completion of the source sequence,
        this buffer is drained on the result sequence. This causes the
        elements to be delayed.

        Keyword arguments:
        count -- Number of elements to take from the end of the source
            sequence.

        Returns an observable sequence containing a single list with the
        specified number of elements from the end of the source
        sequence.
        """
self
count
examples
None