| 1234567891011121314151617181920212223242526272829303132333435363738394041 |
- import { Subscriber } from '../Subscriber';
- /**
- * Creates an instance of an `OperatorSubscriber`.
- * @param destination The downstream subscriber.
- * @param onNext Handles next values, only called if this subscriber is not stopped or closed. Any
- * error that occurs in this function is caught and sent to the `error` method of this subscriber.
- * @param onError Handles errors from the subscription, any errors that occur in this handler are caught
- * and send to the `destination` error handler.
- * @param onComplete Handles completion notification from the subscription. Any errors that occur in
- * this handler are sent to the `destination` error handler.
- * @param onFinalize Additional teardown logic here. This will only be called on teardown if the
- * subscriber itself is not already closed. This is called after all other teardown logic is executed.
- */
- export declare function createOperatorSubscriber<T>(destination: Subscriber<any>, onNext?: (value: T) => void, onComplete?: () => void, onError?: (err: any) => void, onFinalize?: () => void): Subscriber<T>;
- /**
- * A generic helper for allowing operators to be created with a Subscriber and
- * use closures to capture necessary state from the operator function itself.
- */
- export declare class OperatorSubscriber<T> extends Subscriber<T> {
- private onFinalize?;
- private shouldUnsubscribe?;
- /**
- * Creates an instance of an `OperatorSubscriber`.
- * @param destination The downstream subscriber.
- * @param onNext Handles next values, only called if this subscriber is not stopped or closed. Any
- * error that occurs in this function is caught and sent to the `error` method of this subscriber.
- * @param onError Handles errors from the subscription, any errors that occur in this handler are caught
- * and send to the `destination` error handler.
- * @param onComplete Handles completion notification from the subscription. Any errors that occur in
- * this handler are sent to the `destination` error handler.
- * @param onFinalize Additional finalization logic here. This will only be called on finalization if the
- * subscriber itself is not already closed. This is called after all other finalization logic is executed.
- * @param shouldUnsubscribe An optional check to see if an unsubscribe call should truly unsubscribe.
- * NOTE: This currently **ONLY** exists to support the strange behavior of {@link groupBy}, where unsubscription
- * to the resulting observable does not actually disconnect from the source if there are active subscriptions
- * to any grouped observable. (DO NOT EXPOSE OR USE EXTERNALLY!!!)
- */
- constructor(destination: Subscriber<any>, onNext?: (value: T) => void, onComplete?: () => void, onError?: (err: any) => void, onFinalize?: (() => void) | undefined, shouldUnsubscribe?: (() => boolean) | undefined);
- unsubscribe(): void;
- }
- //# sourceMappingURL=OperatorSubscriber.d.ts.map
|
