package 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. id : Id.t;
  2. mutable advance_errors : Core_kernel.Error.t list;
  3. mutable am_advancing : bool;
  4. events : Job_or_event.t Timing_wheel.t;
  5. mutable fired_events : Event.t;
  6. mutable most_recently_fired : Event.t;
  7. handle_fired : Job_or_event.t Alarm.t -> unit;
  8. is_wall_clock : bool;
  9. 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 events : 'a t -> Job_or_event.t Timing_wheel.t
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
val id : 'a t -> Id.t
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.Time_ns.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) Tuple_pool.Slots.t3 Tuple_pool.Pointer.t -> unit) -> 'rw t -> unit
val invariant : 'a t -> unit
OCaml

Innovation. Community. Security.

GitHub Discord Twitter Peertube RSS
About
Changelog Releases Industrial Users Academic Users Why OCaml
Ecosystem
Packages Community Events OCaml Planet Jobs
Resources
Install OCaml Get Started Platform Tools Language Manual Standard Library API Books Exercises Papers OCaml Playground Logo
Policies
Carbon Footprint Governance Privacy Code of Conduct