rx/core/observablebase.py
def buffer(self, buffer_openings=None, buffer_closing_mapper=None) -> 'ObservableBase':
        """
        Projects each element of an observable sequence into zero or
        more buffers.

        Args:
            buffer_openings: Observable sequence whose elements denote
                the creation of windows.
            buffer_closing_mapper: A function invoked to define the
                closing of each produced window. If a closing mapper
                function is specified for the first parameter, this
                parameter is ignored.

        Returns:
            An observable sequence of windows.
        """
        from ..operators.observable.buffer import buffer
        return buffer(self, buffer_openings, buffer_closing_mapper)

        Projects each element of an observable sequence into zero or
        more buffers.

        Args:
            buffer_openings: Observable sequence whose elements denote
                the creation of windows.
            buffer_closing_mapper: A function invoked to define the
                closing of each produced window. If a closing mapper
                function is specified for the first parameter, this
                parameter is ignored.

        Returns:
            An observable sequence of windows.
        
Projects each element of an observable sequence into zero or
more buffers.
Projects each element of an observable sequence into zero or more buffers .
def buffer(self, buffer_openings=None, buffer_closing_mapper=None) -> 'ObservableBase':
        from ..operators.observable.buffer import buffer
        return buffer(self, buffer_openings, buffer_closing_mapper)
def buffer ( self , buffer_openings = None , buffer_closing_mapper = None ) -> 'ObservableBase' : from . . operators . observable . buffer import buffer return buffer ( self , buffer_openings , buffer_closing_mapper )
Projects each element of an observable sequence into zero or
more buffers.
Projects each element of an observable sequence into zero or more buffers .
"""
        Projects each element of an observable sequence into zero or
        more buffers.

        Args:
            buffer_openings: Observable sequence whose elements denote
                the creation of windows.
            buffer_closing_mapper: A function invoked to define the
                closing of each produced window. If a closing mapper
                function is specified for the first parameter, this
                parameter is ignored.

        Returns:
            An observable sequence of windows.
        """
An observable sequence of windows.
An observable sequence of windows .
self
buffer_openings
Observable sequence whose elements denote
the creation of windows.
Observable sequence whose elements denote the creation of windows .
buffer_closing_mapper
A function invoked to define the
closing of each produced window. If a closing mapper
function is specified for the first parameter, this
parameter is ignored.
A function invoked to define the closing of each produced window . If a closing mapper function is specified for the first parameter this parameter is ignored .