import { Z as ZIO, O as Option, E as Exit, A as Async } from './effect-DbEMiMvv.js'; type Empty = { readonly _tag: "Empty"; }; type Emit = { readonly _tag: "Emit"; readonly value: ZIO; }; type Concat = { readonly _tag: "Concat"; readonly left: ZStream; readonly right: ZStream; }; type Flatten = { readonly _tag: "Flatten"; readonly stream: ZStream>; }; type FromPull = { readonly _tag: "FromPull"; readonly pull: ZIO, [A, ZStream]>; }; type Merge = { readonly _tag: "Merge"; readonly left: ZStream; readonly right: ZStream; readonly flip: boolean; }; type Scoped = { readonly _tag: "Scoped"; readonly acquire: ZIO>; readonly release: (exit: Exit) => Async; }; type Managed = { readonly _tag: "Managed"; readonly acquire: ZIO; release: (exit: Exit) => Async; }>; }; type FromArray = { readonly _tag: "FromArray"; readonly values: readonly A[]; }; type ZStream = Empty | Emit | Concat | FromPull | FromArray | Flatten | Merge | Scoped | Managed; type Normalize = (u: unknown) => E; declare const widenOpt: (opt: Option) => Option; declare const fromPull: (pull: ZIO, [A, ZStream]>) => ZStream; declare const unwrapScoped: (acquire: ZIO>, release: (exit: Exit) => Async) => ZStream; declare const managedStream: (acquire: ZIO; release: (exit: Exit) => Async; }>) => ZStream; declare const mergeStream: (left: ZStream, right: ZStream, flip?: boolean) => ZStream; declare const emptyStream: () => ZStream; declare const emitStream: (value: ZIO) => ZStream; declare const concatStream: (left: ZStream, right: ZStream) => ZStream; declare const flattenStream: (stream: ZStream>) => ZStream; declare function merge(left: ZStream, right: ZStream): ZStream; declare function uncons(self: ZStream): ZIO, [A, ZStream]>; declare function assertNever(x: never, msg?: string): never; declare function mapStream(self: ZStream, f: (a: A) => B): ZStream; declare function rangeStream(start: number, end: number): ZStream; declare function zip(left: ZStream, right: ZStream): ZStream; declare function foreachStream(stream: ZStream, f: (a: A) => Async): Async; declare function fromArray(values: readonly A[]): ZStream; declare function collectStream(stream: ZStream): ZIO; type ReadableStreamOptions = { signal?: AbortSignal; onRelease?: () => void; }; declare function streamFromReadableStream(body: ReadableStream | null | undefined, normalizeError: Normalize, options?: ReadableStreamOptions): ZStream; export { type Concat as C, type Emit as E, type Flatten as F, type Managed as M, type Normalize as N, type ReadableStreamOptions as R, type Scoped as S, type ZStream as Z, type Empty as a, type FromArray as b, type FromPull as c, type Merge as d, assertNever as e, collectStream as f, concatStream as g, emitStream as h, emptyStream as i, flattenStream as j, foreachStream as k, fromArray as l, fromPull as m, managedStream as n, mapStream as o, merge as p, mergeStream as q, rangeStream as r, streamFromReadableStream as s, unwrapScoped as t, uncons as u, widenOpt as w, zip as z };