import { Channel } from "@effect/core/stream/Channel/definition/base"; import type { AsyncInputProducer } from "@effect/core/stream/Channel/SingleProducerAsyncInput"; /** * Embed inputs from continuos pulling of a producer. * @tsplus static effect/core/stream/Channel.Aspects embedInput * @tsplus pipeable effect/core/stream/Channel embedInput * @tsplus location "@effect/core/stream/Channel/operations/embedInput" */ export declare function embedInput(input: AsyncInputProducer): (self: import("../definition").Channel) => import("../definition").Channel; //# sourceMappingURL=embedInput.d.ts.map