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
|
