Window¶

Observable.window(window_openings=None, window_closing_selector=None)¶

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

Keyword Arguments:
	window_openings (Observable) – Observable sequence whose elements denote the creation of windows. window_closing_selector (types.FunctionType, 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.
Return type:	(Observable)

Observable.window_with_count(count, skip=None)¶

Projects each element of an observable sequence into zero or more windows which are produced based on element count information.

Example:

xs.window_with_count(10)
xs.window_with_count(10, 1)

Parameters:	count (int) – Length of each window. skip (int, optional) – consecutive windows. If not specified, defaults to the count.
Returns:	an observable sequence of windows.
Return type:	Observable

Observable.window_with_time(timespan, timeshift=None, scheduler=None)¶

Observable.window_with_time_or_count(timespan, count, scheduler=None)¶