import { Stream } from "@effect/core/stream/Stream/definition"; import { Effect } from "@effect/core/io/Effect/definition"; import { Maybe } from "@tsplus/stdlib/data/Maybe/definition"; import { Chunk } from "@tsplus/stdlib/collections/Chunk/definition"; import { Exit } from "@effect/core/io/Exit/definition"; import { Take } from "@effect/core/stream/Take/definition"; import { Channel } from "@effect/core/stream/Channel/definition/base"; /** * Combines the chunks from this stream and the specified stream by repeatedly * applying the function `f` to extract a chunk using both sides and * conceptually "offer" it to the destination stream. `f` can maintain some * internal state to control the combining process, with the initial state * being specified by `s`. * @tsplus static effect/core/stream/Stream.Aspects combineChunks * @tsplus pipeable effect/core/stream/Stream combineChunks * @tsplus location "@effect/core/stream/Stream/operations/combineChunks" */ export declare function combineChunks(that: Stream, s: S, f: (s: S, pullLeft: Effect, Chunk>, pullRight: Effect, Chunk>) => Effect, readonly [Chunk, S]>>): (self: Stream) => Stream; //# sourceMappingURL=combineChunks.d.ts.map