rx/core/observablebase.py
def buffer_with_time_or_count(self, timespan, count) -> 'ObservableBase':
        """Projects each element of an observable sequence into a buffer that
        is completed when either it's full or a given amount of time has
        elapsed.

        >>> # 5s or 50 items in an array
        >>> res = source.buffer_with_time_or_count(5000, 50)
        >>> # 5s or 50 items in an array
        >>> res = source.buffer_with_time_or_count(5000, 50, Scheduler.timeout)

        Args:
            timespan -- Maximum time length of a buffer.
            count -- Maximum element count of a buffer.
            scheduler -- [Optional] Scheduler to run bufferin timers on.
                If not specified, the timeout scheduler is used.

        Returns:
            An observable sequence of buffers.
        """
        from ..operators.observable.bufferwithtimeorcount import buffer_with_time_or_count
        return buffer_with_time_or_count(self, timespan, count)
Projects each element of an observable sequence into a buffer that
        is completed when either it's full or a given amount of time has
        elapsed.

        >>> # 5s or 50 items in an array
        >>> res = source.buffer_with_time_or_count(5000, 50)
        >>> # 5s or 50 items in an array
        >>> res = source.buffer_with_time_or_count(5000, 50, Scheduler.timeout)

        Args:
            timespan -- Maximum time length of a buffer.
            count -- Maximum element count of a buffer.
            scheduler -- [Optional] Scheduler to run bufferin timers on.
                If not specified, the timeout scheduler is used.

        Returns:
            An observable sequence of buffers.
        
Projects each element of an observable sequence into a buffer that
is completed when either it's full or a given amount of time has
elapsed.



- Maximum time length of a buffer.
count -- Maximum element count of a buffer.
scheduler -- [Optional] Scheduler to run bufferin timers on.
If not specified, the timeout scheduler is used.

An observable sequence of buffers.
Projects each element of an observable sequence into a buffer that is completed when either it ' s full or a given amount of time has elapsed . - Maximum time length of a buffer . count -- Maximum element count of a buffer . scheduler -- [ Optional ] Scheduler to run bufferin timers on . If not specified the timeout scheduler is used . An observable sequence of buffers .
def buffer_with_time_or_count(self, timespan, count) -> 'ObservableBase':
        from ..operators.observable.bufferwithtimeorcount import buffer_with_time_or_count
        return buffer_with_time_or_count(self, timespan, count)
def buffer_with_time_or_count ( self , timespan , count ) -> 'ObservableBase' : from . . operators . observable . bufferwithtimeorcount import buffer_with_time_or_count return buffer_with_time_or_count ( self , timespan , count )
Projects each element of an observable sequence into a buffer that
is completed when either it's full or a given amount of time has
elapsed.
Projects each element of an observable sequence into a buffer that is completed when either it ' s full or a given amount of time has elapsed .
"""Projects each element of an observable sequence into a buffer that
        is completed when either it's full or a given amount of time has
        elapsed.

        >>> # 5s or 50 items in an array
        >>> res = source.buffer_with_time_or_count(5000, 50)
        >>> # 5s or 50 items in an array
        >>> res = source.buffer_with_time_or_count(5000, 50, Scheduler.timeout)

        Args:
            timespan -- Maximum time length of a buffer.
            count -- Maximum element count of a buffer.
            scheduler -- [Optional] Scheduler to run bufferin timers on.
                If not specified, the timeout scheduler is used.

        Returns:
            An observable sequence of buffers.
        """
self
timespan
count