package async

  1. Overview
  2. Docs

Module Scheduler.Synchronous_time_source

module Time_ns : sig ... end
module Alarm : sig ... end
module Alarm_precision = Timing_wheel.Alarm_precision
val default_timing_wheel_config : Timing_wheel.Config.t
type callback = unit -> unit
module Id : sig ... end
module T1 : sig ... end
val sexp_of_t : t -> Ppx_sexp_conv_lib.Sexp.t
val invariant : 'a T1.t -> unit
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) -> 'a T1.t -> unit
module Read_write : sig ... end
val id : 'a T1.t -> Id.t
val is_wall_clock : 'a T1.t -> bool
val length : 'a T1.t -> int
val max_allowed_alarm_time : 'a T1.t -> Core_kernel.Time_ns.t
val read_only : [> Core_kernel.read ] T1.t -> t
val fire : 'a T1.t -> T1.Event.t -> unit
val alarm_precision : 'a T1.t -> Core_kernel.Time_ns.Span.t
val now : 'a T1.t -> Core_kernel.Time_ns.t
val timing_wheel_now : 'a T1.t -> Core_kernel.Time_ns.t
val schedule : 'a T1.t -> T1.Event.t -> unit
module Event : sig ... end
val run_after : 'a T1.t -> Time_ns.Span.t -> (unit -> unit) -> unit
val run_at : 'a T1.t -> Time_ns.t -> (unit -> unit) -> unit
val run_at_intervals : 'a T1.t -> Time_ns.Span.t -> (unit -> unit) -> unit
type send_exn = Async_kernel__.Types.Monitor.t -> ?backtrace:[ `Get | `This of Core_kernel.Backtrace.t ] -> exn -> unit
val run_fired_events : 'a T1.t -> send_exn:send_exn option -> unit
val advance_clock : 'a T1.t -> to_:Core_kernel.Time_ns.t -> send_exn:send_exn option -> unit
val fire_past_alarms : 'a T1.t -> send_exn:send_exn option -> unit
val advance_internal : 'a T1.t -> to_:Core_kernel.Time_ns.t -> send_exn:send_exn option -> unit
val prepare_to_advance : 'a T1.t -> send_exn:send_exn option -> unit
val finish_advancing : 'a T1.t -> (unit, Core_kernel.Error.t) Core_kernel._result
val advance_by_alarms : 'a T1.t -> to_:Core_kernel.Time_ns.t -> (unit, Core_kernel.Error.t) Core_kernel._result
val advance_directly : 'a T1.t -> to_:Core_kernel.Time_ns.t -> (unit, Core_kernel.Error.t) Core_kernel._result