import type { IScheduler, ISink, IStream } from '../../stream/index.js';
type ICreateStream<T> = (sink: ISink<T>, scheduler: IScheduler) => Disposable;
export declare const stream: <T>(run: ICreateStream<T>) => Stream<T>;
declare class Stream<T> implements IStream<T> {
    readonly run: ICreateStream<T>;
    constructor(run: ICreateStream<T>);
}
export {};