import { Stream } from "@effect/core/stream/Stream/definition"; /** * Maps each element of this stream to another stream and returns the * non-deterministic merge of those streams, executing up to `n` inner streams * concurrently. When a new stream is created from an element of the source * stream, the oldest executing stream is cancelled. Up to `bufferSize` * elements of the produced streams may be buffered in memory by this * operator. * @tsplus static effect/core/stream/Stream.Aspects flatMapParSwitch * @tsplus pipeable effect/core/stream/Stream flatMapParSwitch * @tsplus location "@effect/core/stream/Stream/operations/flatMapParSwitch" */ export declare function flatMapParSwitch(n: number, f: (a: A) => Stream, bufferSize?: number): (self: import("../definition").Stream) => import("../definition").Stream; //# sourceMappingURL=flatMapParSwitch.d.ts.map