import { Channel } from "@effect/core/stream/Channel/definition/base"; import type { ChildExecutorDecision } from "@effect/core/stream/Channel/ChildExecutorDecision"; import type { UpstreamPullRequest } from "@effect/core/stream/Channel/UpstreamPullRequest"; import type { UpstreamPullStrategy } from "@effect/core/stream/Channel/UpstreamPullStrategy"; /** * Returns a new channel whose outputs are fed to the specified factory * function, which creates new channels in response. These new channels are * sequentially concatenated together, and all their outputs appear as outputs * of the newly returned channel. The provided merging function is used to * merge the terminal values of all channels into the single terminal value of * the returned channel. * @tsplus static effect/core/stream/Channel.Aspects concatMapWithCustom * @tsplus pipeable effect/core/stream/Channel concatMapWithCustom * @tsplus location "@effect/core/stream/Channel/operations/concatMapWithCustom" */ export declare function concatMapWithCustom(f: (o: OutElem) => Channel, g: (o: OutDone, o1: OutDone) => OutDone, h: (o: OutDone, o2: OutDone2) => OutDone3, onPull: (upstreamPullRequest: UpstreamPullRequest) => UpstreamPullStrategy, onEmit: (elem: OutElem2) => ChildExecutorDecision): (self: import("../definition").Channel) => import("../definition").Channel; //# sourceMappingURL=concatMapWithCustom.d.ts.map