Up

Module Coalesced_throttle = Coalesced_throttle

Signature

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.Std.Deferred.t) -> 'a Async.Std.Deferred.t) -> 'a Async.Std.Deferred.t) -> 'a Async.Std.Deferred.t

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