import { P as Pushable } from '../monads-DYUNSJVn.js';
export { B as BatchAsyncParams, b as batchAsync, a as castAsync, c as cloneAsync, g as concatAsync, d as delayAsync, f as filterAsync, h as flatAsync, j as joinAsync, m as mapAsync, s as splitAsync, t as teeAsync, e as teePushableAsync } from '../monads-DYUNSJVn.js';
export { E as EventMessage, s as serializeSSEEvent, a as sseReadableStream, t as transformAsyncIterable } from '../sse-BiMYWw38.js';

type Clonable<T> = T & {
    source: T;
    clone(this: Clonable<T>): T;
};
declare function cloneable<T>(source: AsyncIterable<T>): Clonable<AsyncIterable<T>>;
type PushableCloneable<T> = {
    source: Pushable<T>;
    clone(this: PushableCloneable<T>): AsyncIterable<T>;
    push(value: T): Pushable<T>;
};
declare function clonePushable<T>(source: Pushable<T>): PushableCloneable<T>;

declare function readableStream<T>(iterator: AsyncGenerator<T>, abortSignal: AbortSignal): ReadableStream<T>;

export { type Clonable, type PushableCloneable, clonePushable, cloneable, readableStream };