rx/core/observablebase.py
def window(self, window_openings=None, window_closing_mapper=None) -> 'ObservableBase':
        """Projects each element of an observable sequence into zero or
        more windows.

        Args:
            window_openings -- Observable sequence whose elements denote
                the creation of windows.
            window_closing_mapper -- [Optional] A function invoked to
                define the closing of each produced window. It defines the
                boundaries of the produced windows (a window is started
                when the previous one is closed, resulting in
                non-overlapping windows).

        Returns:
            An observable sequence of windows.
        """
        from ..operators.observable.window import window
        return window(self, window_openings, window_closing_mapper)
Projects each element of an observable sequence into zero or
        more windows.

        Args:
            window_openings -- Observable sequence whose elements denote
                the creation of windows.
            window_closing_mapper -- [Optional] A function invoked to
                define the closing of each produced window. It defines the
                boundaries of the produced windows (a window is started
                when the previous one is closed, resulting in
                non-overlapping windows).

        Returns:
            An observable sequence of windows.
        
Projects each element of an observable sequence into zero or
more windows.

- Observable sequence whose elements denote
the creation of windows.
window_closing_mapper -- [Optional] A function invoked to
define the closing of each produced window. It defines the
boundaries of the produced windows (a window is started
when the previous one is closed, resulting in
non-overlapping windows).

An observable sequence of windows.
Projects each element of an observable sequence into zero or more windows . - Observable sequence whose elements denote the creation of windows . window_closing_mapper -- [ Optional ] A function invoked to define the closing of each produced window . It defines the boundaries of the produced windows ( a window is started when the previous one is closed resulting in non - overlapping windows ) . An observable sequence of windows .
def window(self, window_openings=None, window_closing_mapper=None) -> 'ObservableBase':
        from ..operators.observable.window import window
        return window(self, window_openings, window_closing_mapper)
def window ( self , window_openings = None , window_closing_mapper = None ) -> 'ObservableBase' : from . . operators . observable . window import window return window ( self , window_openings , window_closing_mapper )
Projects each element of an observable sequence into zero or
more windows.
Projects each element of an observable sequence into zero or more windows .
"""Projects each element of an observable sequence into zero or
        more windows.

        Args:
            window_openings -- Observable sequence whose elements denote
                the creation of windows.
            window_closing_mapper -- [Optional] A function invoked to
                define the closing of each produced window. It defines the
                boundaries of the produced windows (a window is started
                when the previous one is closed, resulting in
                non-overlapping windows).

        Returns:
            An observable sequence of windows.
        """
self
window_openings
window_closing_mapper