async
  1. Overview
  2. Docs
package async
Legend:
Library
Module
Module type
Parameter
Class
Class type
module Event : sig ... end
module Job_or_event : sig ... end
type -'rw t = {
  1. mutable advance_errors : Core_kernel.Error.t list;
  2. mutable am_advancing : bool;
  3. events : Job_or_event.t Core_kernel.Timing_wheel_ns.t;
  4. mutable fired_events : Event.t;
  5. mutable most_recently_fired : Event.t;
  6. handle_fired : Job_or_event.t Alarm.t -> unit;
  7. is_wall_clock : bool;
  8. scheduler : Async_kernel__.Types.Scheduler.t;
}
val scheduler : 'a t -> Async_kernel__.Types.Scheduler.t
val is_wall_clock : 'a t -> bool
val handle_fired : 'a t -> Job_or_event.t Alarm.t -> unit
val most_recently_fired : 'a t -> Event.t
val set_most_recently_fired : 'a t -> Event.t -> unit
val fired_events : 'a t -> Event.t
val set_fired_events : 'a t -> Event.t -> unit
val am_advancing : 'a t -> bool
val set_am_advancing : 'a t -> bool -> unit
val advance_errors : 'a t -> Core_kernel.Error.t list
val set_advance_errors : 'a t -> Core_kernel.Error.t list -> unit
module Fields : sig ... end
val sexp_of_t : 'a -> 'b t -> Ppx_sexp_conv_lib.Sexp.t
val timing_wheel_now : 'a t -> Core_kernel.Timing_wheel_ns.Time.t
val is_in_fired_events : 'a t -> Event.t -> bool
val invariant_with_jobs : job: ((Async_kernel__.Types.Execution_context.t, Obj.t -> unit, Obj.t) Core_kernel.Pool.Slots.t3 Core_kernel.Pool.Pointer.t -> unit) -> 'rw t -> unit
val invariant : 'a t -> unit