Module Async_extended.Coalesced_throttle

type 'a t

A coalesced throttle.

val create : unit ‑> 'a t

Create a coalesced throttle.

val enqueue : 'a t ‑> (maybe_abort:(continue:(unit ‑> 'a Async.Deferred.t) ‑> 'a Async.Deferred.t) ‑> 'a Async.Deferred.t) ‑> 'a Async.Deferred.t

Enqueue a job, which may be coalesced into a later job.