Sha256: ba719b7bcde3f1eb06ca8722f47356c75f78b0ad5f968c037973cbb51350dcda

Contents?: true

Size: 1.69 KB

Versions: 49

Compression:

Stored size: 1.69 KB

Contents

/** PURE_IMPORTS_START .._operators_window PURE_IMPORTS_END */
import { window as higherOrder } from '../operators/window';
/**
 * Branch out the source Observable values as a nested Observable whenever
 * `windowBoundaries` emits.
 *
 * <span class="informal">It's like {@link buffer}, but emits a nested Observable
 * instead of an array.</span>
 *
 * <img src="./img/window.png" width="100%">
 *
 * Returns an Observable that emits windows of items it collects from the source
 * Observable. The output Observable emits connected, non-overlapping
 * windows. It emits the current window and opens a new one whenever the
 * Observable `windowBoundaries` emits an item. Because each window is an
 * Observable, the output is a higher-order Observable.
 *
 * @example <caption>In every window of 1 second each, emit at most 2 click events</caption>
 * var clicks = Rx.Observable.fromEvent(document, 'click');
 * var interval = Rx.Observable.interval(1000);
 * var result = clicks.window(interval)
 *   .map(win => win.take(2)) // each window has at most 2 emissions
 *   .mergeAll(); // flatten the Observable-of-Observables
 * result.subscribe(x => console.log(x));
 *
 * @see {@link windowCount}
 * @see {@link windowTime}
 * @see {@link windowToggle}
 * @see {@link windowWhen}
 * @see {@link buffer}
 *
 * @param {Observable<any>} windowBoundaries An Observable that completes the
 * previous window and starts a new window.
 * @return {Observable<Observable<T>>} An Observable of windows, which are
 * Observables emitting values of the source Observable.
 * @method window
 * @owner Observable
 */
export function window(windowBoundaries) {
    return higherOrder(windowBoundaries)(this);
}
//# sourceMappingURL=window.js.map

Version data entries

49 entries across 49 versions & 4 rubygems

Version Path
ilog-0.4.1 node_modules/rxjs/_esm5/operator/window.js
ilog-0.4.0 node_modules/rxjs/_esm5/operator/window.js
ilog-0.3.3 node_modules/rxjs/_esm5/operator/window.js
govuk_publishing_components-18.0.0 node_modules/rxjs/_esm5/operator/window.js
govuk_publishing_components-17.21.0 node_modules/rxjs/_esm5/operator/window.js
govuk_publishing_components-17.20.0 node_modules/rxjs/_esm5/operator/window.js
govuk_publishing_components-17.19.1 node_modules/rxjs/_esm5/operator/window.js
govuk_publishing_components-17.19.0 node_modules/rxjs/_esm5/operator/window.js
govuk_publishing_components-17.18.0 node_modules/rxjs/_esm5/operator/window.js
govuk_publishing_components-17.17.0 node_modules/rxjs/_esm5/operator/window.js
govuk_publishing_components-17.16.0 node_modules/rxjs/_esm5/operator/window.js
govuk_publishing_components-17.15.0 node_modules/rxjs/_esm5/operator/window.js
govuk_publishing_components-17.14.0 node_modules/rxjs/_esm5/operator/window.js
govuk_publishing_components-17.13.0 node_modules/rxjs/_esm5/operator/window.js
govuk_publishing_components-17.12.2 node_modules/rxjs/_esm5/operator/window.js
govuk_publishing_components-17.12.1 node_modules/rxjs/_esm5/operator/window.js
govuk_publishing_components-17.12.0 node_modules/rxjs/_esm5/operator/window.js
govuk_publishing_components-17.11.0 node_modules/rxjs/_esm5/operator/window.js
govuk_publishing_components-17.10.0 node_modules/rxjs/_esm5/operator/window.js
govuk_publishing_components-17.9.0 node_modules/rxjs/_esm5/operator/window.js