module Event : sig ... end
module Job_or_event : sig ... end
type -'rw t
= 'rw Async_kernel__.Types.Time_source.t1
=
{
mutable advance_errors : Core_kernel.Error.t list; |
mutable am_advancing : bool; |
events : Job_or_event.t Core_kernel.Timing_wheel_ns.t; |
mutable fired_events : Event.t; |
handle_fired : Job_or_event.t Alarm.t ‑> unit; |
is_wall_clock : bool; |
scheduler : Async_kernel__.Scheduler0.t; |
}
val scheduler : 'a t ‑> Async_kernel__.Scheduler0.t
val is_wall_clock : 'a t ‑> bool
val handle_fired : 'a t ‑> Job_or_event.t Alarm.t ‑> unit
val events : 'a t ‑> Job_or_event.t Core_kernel.Timing_wheel_ns.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
module Fields : sig ... end
val sexp_of_t : 'a ‑> 'b t ‑> Sexplib.Sexp.t
val timing_wheel_now : 'a t ‑> Core_kernel.Timing_wheel_ns.Time.t
val invariant : 'a t ‑> unit