import { IDisposable } from './disposable';
import { EventQueue } from './event';
import type { Readable } from 'stream';
export interface IReadableStream<T, E extends Error = Error> {
    on(event: 'data', listener: (chunk: T) => void): this;
    on(event: 'end', listener: () => void): this;
    on(event: 'error', listener: (err: E) => void): this;
    on(event: string, listener: (...args: any[]) => void): this;
}
export declare function isReadableStream(stream: any): stream is Readable;
export interface IListenReadableOptions<T, E> {
    onData(data: T): void;
    onEnd(): void;
    onError?(error: E): void;
}
export declare function listenReadable<T = Uint8Array, E extends Error = Error>(stream: IReadableStream<T, E>, options: IListenReadableOptions<T, E>): void;
export declare function listenGroupReadable<T = Uint8Array, E extends Error = Error>(streams: IReadableStream<T, E>[], options: IListenReadableOptions<T, E>): void;
export declare class SumiReadableStream<T, E extends Error = Error> implements IReadableStream<T, E> {
    protected dataQueue: EventQueue<T>;
    protected endQueue: EventQueue<void>;
    protected errorQueue: EventQueue<E>;
    on(event: 'error', listener: (err: E) => void): this;
    on(event: 'data', listener: (chunk: T) => void): this;
    on(event: 'end', listener: () => void): this;
    on(event: string, listener: (...args: any[]) => void): this;
    onData(cb: (data: T) => void): IDisposable;
    onEnd(cb: () => void): IDisposable;
    onError(cb: (err: E) => void): IDisposable;
    emitData(buffer: T): void;
    emitError(err: E): void;
    end(): void;
    abort(): void;
}
//# sourceMappingURL=stream.d.ts.map