diff options
Diffstat (limited to 'tools/node_modules/eslint/node_modules/rxjs/internal/operators/buffer.d.ts')
-rw-r--r-- | tools/node_modules/eslint/node_modules/rxjs/internal/operators/buffer.d.ts | 43 |
1 files changed, 0 insertions, 43 deletions
diff --git a/tools/node_modules/eslint/node_modules/rxjs/internal/operators/buffer.d.ts b/tools/node_modules/eslint/node_modules/rxjs/internal/operators/buffer.d.ts deleted file mode 100644 index 8d88fd21ff..0000000000 --- a/tools/node_modules/eslint/node_modules/rxjs/internal/operators/buffer.d.ts +++ /dev/null @@ -1,43 +0,0 @@ -import { Observable } from '../Observable'; -import { OperatorFunction } from '../types'; -/** - * Buffers the source Observable values until `closingNotifier` emits. - * - * <span class="informal">Collects values from the past as an array, and emits - * that array only when another Observable emits.</span> - * - * ![](content/img/buffer.png) - * - * Buffers the incoming Observable values until the given `closingNotifier` - * Observable emits a value, at which point it emits the buffer on the output - * Observable and starts a new buffer internally, awaiting the next time - * `closingNotifier` emits. - * - * ## Example - * - * On every click, emit array of most recent interval events - * - * ```javascript - * import { fromEvent, interval } from 'rxjs'; - * import { buffer } from 'rxjs/operators'; - * - * const clicks = fromEvent(document, 'click'); - * const interval = interval(1000); - * const buffered = interval.pipe(buffer(clicks)); - * buffered.subscribe(x => console.log(x)); - * ``` - * - * @see {@link bufferCount} - * @see {@link bufferTime} - * @see {@link bufferToggle} - * @see {@link bufferWhen} - * @see {@link window} - * - * @param {Observable<any>} closingNotifier An Observable that signals the - * buffer to be emitted on the output Observable. - * @return {Observable<T[]>} An Observable of buffers, which are arrays of - * values. - * @method buffer - * @owner Observable - */ -export declare function buffer<T>(closingNotifier: Observable<any>): OperatorFunction<T, T[]>; |