export type StrictStream<Type> = AsyncIterable<Type>;
export type StrictStreamOf<Input> = StrictStream<Input> & {
    pipe<Output>(mapper: StrictStreamMapper<Input, Output>): StrictStreamOf<Output>;
};
export type StrictStreamLike<Type> = AsyncIterable<Type> | Iterable<Type> | Type[];
export type StrictStreamMapper<Input, Output> = (stream: StrictStream<Input>) => StrictStream<Output>;
export type Promised<Type> = Type | Promise<Type>;
export type StrictStreamPlumber<In, Out> = StrictStreamMapper<In, Out> & {
    pipe<Output>(mapper: StrictStreamMapper<Out, Output>): StrictStreamPlumber<In, Output>;
};
export declare function of<Input>(inputStream: StrictStream<Input>): StrictStreamOf<Input>;
export declare function pipe<In, Out>(mapper: StrictStreamMapper<In, Out>): StrictStreamPlumber<In, Out>;
export declare function run<Type, Default = undefined>(stream: StrictStream<Type>, defaultValue?: Default): Promise<Type | Default>;