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 sliding 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 bufferSliding * @tsplus pipeable effect/core/stream/Stream bufferSliding * @tsplus location "@effect/core/stream/Stream/operations/bufferSliding" */ export declare function bufferSliding(capacity: number): (self: import("../definition").Stream) => import("../definition").Stream; //# sourceMappingURL=bufferSliding.d.ts.map