diff options
| author | Pinapelz <yukais@pinapelz.com> | 2025-06-29 11:49:28 -0700 |
|---|---|---|
| committer | Pinapelz <yukais@pinapelz.com> | 2025-06-29 11:49:28 -0700 |
| commit | d55b767039605256c736166a942a9138e3eacfd7 (patch) | |
| tree | 947063b634c50d438a794325f13275e134aa5993 /node_modules/rxjs/src/internal/operators/toArray.ts | |
| parent | 864ce67d89c77d8ef9c3361f80d619853abcf91c (diff) | |
remove dev node_modules (oops)
Diffstat (limited to 'node_modules/rxjs/src/internal/operators/toArray.ts')
| -rw-r--r-- | node_modules/rxjs/src/internal/operators/toArray.ts | 44 |
1 files changed, 0 insertions, 44 deletions
diff --git a/node_modules/rxjs/src/internal/operators/toArray.ts b/node_modules/rxjs/src/internal/operators/toArray.ts deleted file mode 100644 index 2678472..0000000 --- a/node_modules/rxjs/src/internal/operators/toArray.ts +++ /dev/null @@ -1,44 +0,0 @@ -import { reduce } from './reduce'; -import { OperatorFunction } from '../types'; -import { operate } from '../util/lift'; - -const arrReducer = (arr: any[], value: any) => (arr.push(value), arr); - -/** - * Collects all source emissions and emits them as an array when the source completes. - * - * <span class="informal">Get all values inside an array when the source completes</span> - * - *  - * - * `toArray` will wait until the source Observable completes before emitting - * the array containing all emissions. When the source Observable errors no - * array will be emitted. - * - * ## Example - * - * ```ts - * import { interval, take, toArray } from 'rxjs'; - * - * const source = interval(1000); - * const example = source.pipe( - * take(10), - * toArray() - * ); - * - * example.subscribe(value => console.log(value)); - * - * // output: [0, 1, 2, 3, 4, 5, 6, 7, 8, 9] - * ``` - * - * @return A function that returns an Observable that emits an array of items - * emitted by the source Observable when source completes. - */ -export function toArray<T>(): OperatorFunction<T, T[]> { - // Because arrays are mutable, and we're mutating the array in this - // reducer process, we have to encapsulate the creation of the initial - // array within this `operate` function. - return operate((source, subscriber) => { - reduce(arrReducer, [] as T[])(source).subscribe(subscriber); - }); -} |
