import { Stream } from "@effect/core/stream/Stream/definition"; import { Take } from "@effect/core/stream/Take/definition"; import { Deferred } from "@effect/core/io/Deferred/definition"; /** * Allows a faster producer to progress independently of a slower consumer by * buffering up to `capacity` elements in a dropping queue. * * This combinator destroys the chunking structure. It's recommended to use * rechunk afterwards. * * Note: prefer capacities that are powers of 2 for better performance. * @tsplus static effect/core/stream/Stream.Aspects bufferDropping * @tsplus pipeable effect/core/stream/Stream bufferDropping * @tsplus location "@effect/core/stream/Stream/operations/bufferDropping" */ export declare function bufferDropping(capacity: number): (self: import("../definition").Stream) => import("../definition").Stream; //# sourceMappingURL=bufferDropping.d.ts.map