import { Stream, Source, Sink, Disposable, Scheduler } from '@tempest/core';
export declare function flatten<T>(stream: Stream<Stream<T>>): Stream<T>;
export declare class Flatten<T> implements Source<T> {
    private source;
    constructor(source: Source<Stream<T>>);
    run(sink: Sink<T>, scheduler: Scheduler): Disposable<T>;
}