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/every.ts | |
| parent | 864ce67d89c77d8ef9c3361f80d619853abcf91c (diff) | |
remove dev node_modules (oops)
Diffstat (limited to 'node_modules/rxjs/src/internal/operators/every.ts')
| -rw-r--r-- | node_modules/rxjs/src/internal/operators/every.ts | 66 |
1 files changed, 0 insertions, 66 deletions
diff --git a/node_modules/rxjs/src/internal/operators/every.ts b/node_modules/rxjs/src/internal/operators/every.ts deleted file mode 100644 index a6a86bf..0000000 --- a/node_modules/rxjs/src/internal/operators/every.ts +++ /dev/null @@ -1,66 +0,0 @@ -import { Observable } from '../Observable'; -import { Falsy, OperatorFunction } from '../types'; -import { operate } from '../util/lift'; -import { createOperatorSubscriber } from './OperatorSubscriber'; - -export function every<T>(predicate: BooleanConstructor): OperatorFunction<T, Exclude<T, Falsy> extends never ? false : boolean>; -/** @deprecated Use a closure instead of a `thisArg`. Signatures accepting a `thisArg` will be removed in v8. */ -export function every<T>( - predicate: BooleanConstructor, - thisArg: any -): OperatorFunction<T, Exclude<T, Falsy> extends never ? false : boolean>; -/** @deprecated Use a closure instead of a `thisArg`. Signatures accepting a `thisArg` will be removed in v8. */ -export function every<T, A>( - predicate: (this: A, value: T, index: number, source: Observable<T>) => boolean, - thisArg: A -): OperatorFunction<T, boolean>; -export function every<T>(predicate: (value: T, index: number, source: Observable<T>) => boolean): OperatorFunction<T, boolean>; - -/** - * Returns an Observable that emits whether or not every item of the source satisfies the condition specified. - * - * <span class="informal">If all values pass predicate before the source completes, emits true before completion, - * otherwise emit false, then complete.</span> - * - *  - * - * ## Example - * - * A simple example emitting true if all elements are less than 5, false otherwise - * - * ```ts - * import { of, every } from 'rxjs'; - * - * of(1, 2, 3, 4, 5, 6) - * .pipe(every(x => x < 5)) - * .subscribe(x => console.log(x)); // -> false - * ``` - * - * @param predicate A function for determining if an item meets a specified condition. - * @param thisArg Optional object to use for `this` in the callback. - * @return A function that returns an Observable of booleans that determines if - * all items of the source Observable meet the condition specified. - */ -export function every<T>( - predicate: (value: T, index: number, source: Observable<T>) => boolean, - thisArg?: any -): OperatorFunction<T, boolean> { - return operate((source, subscriber) => { - let index = 0; - source.subscribe( - createOperatorSubscriber( - subscriber, - (value) => { - if (!predicate.call(thisArg, value, index++, source)) { - subscriber.next(false); - subscriber.complete(); - } - }, - () => { - subscriber.next(true); - subscriber.complete(); - } - ) - ); - }); -} |
