import { Sink } from "@effect/core/stream/Sink/definition/base"; import { Stream } from "@effect/core/stream/Stream/definition"; import { Chunk } from "@tsplus/stdlib/collections/Chunk/definition"; import { Channel } from "@effect/core/stream/Channel/definition/base"; import { AtomicReference } from "@tsplus/stdlib/data/AtomicReference"; /** * Applies the transducer to the stream and emits its outputs. * @tsplus static effect/core/stream/Stream.Aspects fromSink * @tsplus pipeable effect/core/stream/Stream transduce * @tsplus location "@effect/core/stream/Stream/operations/transduce" */ export declare function transduce(sink: Sink): (self: import("../definition").Stream) => import("../definition").Stream; //# sourceMappingURL=transduce.d.ts.map