// ets_tracing: off import type * as CL from "../../../../Clock/index.js" import type * as CK from "../../../../Collections/Immutable/Chunk/index.js" import * as T from "../../../../Effect/index.js" import type * as C from "../core.js" import * as ThrottleEnforceEffect from "./throttleEnforceEffect.js" /** * Throttles the chunks of this stream according to the given bandwidth parameters using the token bucket * algorithm. Allows for burst in the processing of elements by allowing the token bucket to accumulate * tokens up to a `units + burst` threshold. Chunks that do not meet the bandwidth constraints are dropped. * The weight of each chunk is determined by the `costFn` function. */ export function throttleEnforce_( self: C.Stream, units: number, duration: number, costFn: (c: CK.Chunk) => number, burst = 0 ): C.Stream { return ThrottleEnforceEffect.throttleEnforceEffect_( self, units, duration, (as) => T.succeed(costFn(as)), burst ) } /** * Throttles the chunks of this stream according to the given bandwidth parameters using the token bucket * algorithm. Allows for burst in the processing of elements by allowing the token bucket to accumulate * tokens up to a `units + burst` threshold. Chunks that do not meet the bandwidth constraints are dropped. * The weight of each chunk is determined by the `costFn` function. * * @ets_data_first throttleEnforce_ */ export function throttleEnforce( units: number, duration: number, costFn: (c: CK.Chunk) => number, burst = 0 ) { return (self: C.Stream) => throttleEnforce_(self, units, duration, costFn, burst) }