Rx.Observable.prototype.window([windowOpenings], [windowBoundaries], windowClosingSelector)

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

// With window closing selector
Rx.Observable.prototype.window(windowClosingSelector);

// With window opening and window closing selector
Rx.Observable.prototype.window(windowOpenings, windowClosingSelector);

// With boundaries
Rx.Observable.prototype.window(windowBoundaries);

参数

1. [windowOpenings] (Observable): Observable sequence whose elements denote the creation of new windows 2.[windowBoundaries] (Observable): Sequence of window boundary markers. The current window is closed and a new window is opened upon receiving a boundary marker.
2. windowClosingSelector (Function): A function invoked to define the closing of each produced window.

返回值

(Observable): An observable sequence of windows.

例

With window boundaries

With window opening and window closing selector

With openings and closings