rx/core/observablebase.py
def buffer_with_time(self, timespan, timeshift=None) -> 'ObservableBase':
        """Projects each element of an observable sequence into zero or
        more buffers which are produced based on timing information.

        Examples:
            # non-overlapping segments of 1 second
            >>> res = xs.buffer_with_time(1000)
            # segments of 1 second with time shift 0.5 seconds
            >>> res = xs.buffer_with_time(1000, 500)

        Args:
            timespan: Length of each buffer (specified as an integer
                denoting milliseconds).
            timeshift: Interval between creation of consecutive buffers
                (specified as an integer denoting milliseconds), or an
                optional scheduler parameter. If not specified, the time
                shift corresponds to the timespan parameter, resulting
                in non-overlapping adjacent buffers.

        Returns:
            An observable sequence of buffers.
        """
        from ..operators.observable.bufferwithtime import buffer_with_time
        return buffer_with_time(self, timespan, timeshift)
Projects each element of an observable sequence into zero or
        more buffers which are produced based on timing information.

        Examples:
            # non-overlapping segments of 1 second
            >>> res = xs.buffer_with_time(1000)
            # segments of 1 second with time shift 0.5 seconds
            >>> res = xs.buffer_with_time(1000, 500)

        Args:
            timespan: Length of each buffer (specified as an integer
                denoting milliseconds).
            timeshift: Interval between creation of consecutive buffers
                (specified as an integer denoting milliseconds), or an
                optional scheduler parameter. If not specified, the time
                shift corresponds to the timespan parameter, resulting
                in non-overlapping adjacent buffers.

        Returns:
            An observable sequence of buffers.
        
Projects each element of an observable sequence into zero or
more buffers which are produced based on timing information.
Projects each element of an observable sequence into zero or more buffers which are produced based on timing information .
def buffer_with_time(self, timespan, timeshift=None) -> 'ObservableBase':
        from ..operators.observable.bufferwithtime import buffer_with_time
        return buffer_with_time(self, timespan, timeshift)
def buffer_with_time ( self , timespan , timeshift = None ) -> 'ObservableBase' : from . . operators . observable . bufferwithtime import buffer_with_time return buffer_with_time ( self , timespan , timeshift )
Projects each element of an observable sequence into zero or
more buffers which are produced based on timing information.
Projects each element of an observable sequence into zero or more buffers which are produced based on timing information .
"""Projects each element of an observable sequence into zero or
        more buffers which are produced based on timing information.

        Examples:
            # non-overlapping segments of 1 second
            >>> res = xs.buffer_with_time(1000)
            # segments of 1 second with time shift 0.5 seconds
            >>> res = xs.buffer_with_time(1000, 500)

        Args:
            timespan: Length of each buffer (specified as an integer
                denoting milliseconds).
            timeshift: Interval between creation of consecutive buffers
                (specified as an integer denoting milliseconds), or an
                optional scheduler parameter. If not specified, the time
                shift corresponds to the timespan parameter, resulting
                in non-overlapping adjacent buffers.

        Returns:
            An observable sequence of buffers.
        """
An observable sequence of buffers.
An observable sequence of buffers .
self
timespan
Length of each buffer (specified as an integer
denoting milliseconds).
Length of each buffer ( specified as an integer denoting milliseconds ) .
timeshift
Interval between creation of consecutive buffers
(specified as an integer denoting milliseconds), or an
optional scheduler parameter. If not specified, the time
shift corresponds to the timespan parameter, resulting
in non-overlapping adjacent buffers.
Interval between creation of consecutive buffers ( specified as an integer denoting milliseconds ) or an optional scheduler parameter . If not specified the time shift corresponds to the timespan parameter resulting in non - overlapping adjacent buffers .
examples
non-overlapping segments of 1 second
>>> res = xs.buffer_with_time(1000)
segments of 1 second with time shift 0.5 seconds
>>> res = xs.buffer_with_time(1000, 500)
non - overlapping segments of 1 second >>> res = xs . buffer_with_time ( 1000 ) segments of 1 second with time shift 0 . 5 seconds >>> res = xs . buffer_with_time ( 1000 500 )