/**
 * Copyright (c) 2017-present A. Matías Quezada <amatiasq@gmail.com>
 */
export default class StreamSubscription<T = any> extends Promise<T> {
    protected onCancel: OnCancelCallback;
    protected onResolve: PromiseResolver<T>;
    protected onReject: PromiseRejector;
    constructor(executor: PromiseExecutor<T>);
    cancel(): void;
    then<TResult1 = T, TResult2 = never>(onfulfilled?: PromiseListener<T, TResult1>, onrejected?: PromiseListener<any, TResult2>): StreamSubscription<TResult1 | TResult2>;
}
export declare type PromiseExecutor<T> = (resolve: PromiseResolver<T>, reject: PromiseRejector) => StreamSubscription | OnCancelCallback | void;
export declare type PromiseResolver<T> = (value?: T | PromiseLike<T>) => void;
export declare type PromiseRejector = (value?: Error | PromiseLike<Error>) => void;
export declare type PromiseListener<TInput, TOutput> = ((value: TInput) => TOutput | PromiseLike<TOutput>) | undefined | null;
export declare type OnCancelCallback = () => void;