export interface EventStream<T> {
    iterable: AsyncIterable<T>;
    push: (value: T) => void;
    close: () => void;
}
export declare function createEventStream<T>(): EventStream<T>;