sig
type t = Throttle.t
val invariant : t -> unit
val create : continue_on_error:bool -> max_concurrent_jobs:int -> t
type 'a outcome = [ `Aborted | `Ok of 'a | `Raised of exn ]
module Job :
sig
type 'a t = 'a Throttle.Job.t
val create : (unit -> 'a Deferred.t) -> 'a t
val result : 'a t -> 'a outcome Deferred.t
end
val enqueue_job : t -> 'a Job.t -> unit
val enqueue' : t -> (unit -> 'a Deferred.t) -> 'a outcome Deferred.t
val enqueue : t -> (unit -> 'a Deferred.t) -> 'a Deferred.t
val prior_jobs_done : t -> unit Deferred.t
val num_jobs_waiting_to_start : t -> int
module Sequencer :
sig
type 'a t = 'a Throttle.Sequencer.t
val create : ?continue_on_error:bool -> 'a -> 'a t
val enqueue : 'a t -> ('a -> 'b Deferred.t) -> 'b Deferred.t
val num_jobs_waiting_to_start : 'a t -> int
end
val sexp_of_t : t -> Sexplib.Sexp.t
val ounit_tests : unit -> OUnit.test
end