import { Enqueue } from "@effect/core/io/Queue/definition/common"; import { Take } from "@effect/core/stream/Take/definition"; import { Stream } from "@effect/core/stream/Stream/definition"; import { Effect } from "@effect/core/io/Effect/definition"; import { Scope } from "@effect/core/io/Scope/definition"; import { Channel } from "@effect/core/stream/Channel/definition/base"; import { Chunk } from "@tsplus/stdlib/collections/Chunk/definition"; /** * Like `Stream.runIntoQueue`, but provides the result as a scoped effect to * allow for scope composition. * @tsplus static effect/core/stream/Stream.Aspects runIntoQueueScoped * @tsplus pipeable effect/core/stream/Stream runIntoQueueScoped * @tsplus location "@effect/core/stream/Stream/operations/runIntoQueueScoped" */ export declare function runIntoQueueScoped(queue: Enqueue>): (self: import("../definition").Stream) => import("../../../io/Effect").Effect; //# sourceMappingURL=runIntoQueueScoped.d.ts.map