import StreamSubscription from './subscription';
export default class ReadableStream<T> {
    private onSubscribe;
    static fromEvent<T>(object: IEventEmitter<T>, event: string, takeOnly?: number): ReadableStream<T>;
    static merge<T>(...streams: Array<ReadableStream<T>>): ReadableStream<T>;
    constructor(onSubscribe: ReadableStreamSource<T>);
    subscribe(iterator?: (value: T) => CancelSubscription | void): StreamSubscription<any>;
    forEach(iterator: ReadableIterator<T>): StreamSubscription<any>;
    map<TOut>(mapper: ReadableMapper<T, TOut>): ReadableStream<TOut>;
    flatMap<TOut>(mapper: ReadableMapper<T, TOut | IIterable<TOut>>): ReadableStream<TOut>;
    take(count: number): ReadableStream<T>;
    takeUntil(stopper: Promise<{}>): ReadableStream<T>;
    debounce(milliseconds: number): ReadableStream<T[]>;
    debounce<TOut>(milliseconds: number, join: (list: T[]) => TOut): ReadableStream<TOut>;
}
export declare type IteratorBase<T, TIndex, TCollection, TOutput> = (value: T, index: TIndex, collection: TCollection) => TOutput;
export declare type ReadableMapper<TInput, TOutput> = IteratorBase<TInput, number, ReadableStream<TInput>, TOutput>;
export declare type ReadableIterator<T> = ReadableMapper<T, void>;
export declare type CancelSubscription = StreamSubscription | (() => void);
export declare type ReadableStreamOnNext<T> = (value: T) => void;
export declare type ReadableStreamOnNextCancellable<T> = (value: T) => CancelSubscription;
export declare type ReadableStreamOnError = (error: Error) => void;
export declare type ReadableStreamOnComplete = () => void;
export declare type ReadableStreamSource<T> = (push: ReadableStreamOnNext<T> | ReadableStreamOnNextCancellable<T>, error?: ReadableStreamOnError, complete?: ReadableStreamOnComplete) => CancelSubscription | void;
export interface IIterable<T> {
    forEach(iterator: (value: T) => void): void;
}
export declare type IEventEmitter<T> = IEventEmitterOn<T> | IEventEmitterAdd<T>;
export interface IEventEmitterOn<T> {
    on(signal: string, listener: (event: T) => void): void;
}
export interface IEventEmitterAdd<T> {
    addEventListener(signal: string, listener: (event: T) => void): void;
}