import { Sink } from "@effect/core/stream/Sink/definition/base"; import { Exit } from "@effect/core/io/Exit/definition"; import { Either } from "@tsplus/stdlib/data/Either/definition"; import { Chunk } from "@tsplus/stdlib/collections/Chunk/definition"; import { MergeDecision } from "@effect/core/stream/Channel/MergeDecision"; /** * Runs both sinks in parallel on the input, using the specified merge * function as soon as one result or the other has been computed. * @tsplus static effect/core/stream/Sink.Aspects raceWith * @tsplus pipeable effect/core/stream/Sink raceWith * @tsplus location "@effect/core/stream/Sink/operations/raceWith" */ export declare function raceWith(that: Sink, leftDone: (exit: Exit) => MergeDecision, rightDone: (exit: Exit) => MergeDecision, capacity?: number): (self: import("../definition").Sink) => import("../definition").Sink; //# sourceMappingURL=raceWith.d.ts.map