import { Duration } from "@tsplus/stdlib/data/Duration"; import { Stream } from "@effect/core/stream/Stream/definition"; import { Chunk } from "@tsplus/stdlib/collections/Chunk/definition"; /** * Partitions the stream with the specified chunkSize or until the specified * duration has passed, whichever is satisfied first. * @tsplus static effect/core/stream/Stream.Aspects groupedWithin * @tsplus pipeable effect/core/stream/Stream groupedWithin * @tsplus location "@effect/core/stream/Stream/operations/groupedWithin" */ export declare function groupedWithin(chunkSize: number, within: Duration): (self: import("../definition").Stream) => import("../definition").Stream>; //# sourceMappingURL=groupedWithin.d.ts.map