1234567891011121314151617181920212223242526272829303132 |
- import { Observable } from '../Observable';
- import { Operator } from '../Operator';
- import { Subscriber } from '../Subscriber';
- import { OperatorFunction, MonoTypeOperatorFunction } from '../interfaces';
- export declare function find<T, S extends T>(predicate: (value: T, index: number, source: Observable<T>) => value is S, thisArg?: any): OperatorFunction<T, S>;
- export declare function find<T, S extends T>(predicate: (value: T, index: number) => value is S, thisArg?: any): OperatorFunction<T, S>;
- export declare function find<T>(predicate: (value: T, index: number, source: Observable<T>) => boolean, thisArg?: any): MonoTypeOperatorFunction<T>;
- export declare function find<T>(predicate: (value: T, index: number) => boolean, thisArg?: any): MonoTypeOperatorFunction<T>;
- export declare class FindValueOperator<T> implements Operator<T, T> {
- private predicate;
- private source;
- private yieldIndex;
- private thisArg;
- constructor(predicate: (value: T, index: number, source: Observable<T>) => boolean, source: Observable<T>, yieldIndex: boolean, thisArg?: any);
- call(observer: Subscriber<T>, source: any): any;
- }
- /**
- * We need this JSDoc comment for affecting ESDoc.
- * @ignore
- * @extends {Ignored}
- */
- export declare class FindValueSubscriber<T> extends Subscriber<T> {
- private predicate;
- private source;
- private yieldIndex;
- private thisArg;
- private index;
- constructor(destination: Subscriber<T>, predicate: (value: T, index: number, source: Observable<T>) => boolean, source: Observable<T>, yieldIndex: boolean, thisArg?: any);
- private notifyComplete(value);
- protected _next(value: T): void;
- protected _complete(): void;
- }
|