export function stream(source: StreamSource, options?: StreamOptions): StreamResult;
export function consume(source: ConsumeSource, options?: ConsumeOptions): ConsumeResult;
export class StreamError extends Error {
    constructor(message: string, code: string);
    public code: string;
}
export type Handlers = {
    onFinish?: () => any;
};
export type StreamSource = any;
export type StreamResult = any;
export type StreamOptions = {} & Handlers;
export type ConsumeSource = any;
export type ConsumeResult = any;
export type ConsumeOptions = {} & Handlers;