import { Input } from "./async";
export interface ComposeFn<T, R> {
    (input: AsyncIterable<T>): AsyncIterable<R>;
}
export declare function compose<T, I extends Input<T>, R>(fn: ComposeFn<T, R>, ...streams: I[]): AsyncIterable<R[]>;