Up

module Coalesced_throttle

: sig

A throttle that coalesces jobs, only fully executing the most recent job.

#
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.

end