package async_kernel

  1. Overview
  2. Docs
Legend:
Library
Module
Module type
Parameter
Class
Class type
module Status : sig ... end
type event
val sexp_of_event : event -> Ppx_sexp_conv_lib.Sexp.t
module Option : sig ... end
type t = {
  1. mutable alarm : Async_kernel__.Types.Job_or_event.t Timing_wheel.Alarm.t;
  2. mutable at : Core.Time_ns.t;
  3. callback : unit -> unit;
  4. execution_context : Execution_context.t;
  5. mutable interval : Core.Core_private.Time_ns_alternate_sexp.Span.t option;
  6. mutable next_fired : Option.t;
  7. mutable prev_fired : Option.t;
  8. mutable status : Status.t;
}
val status : t -> Status.t
val prev_fired : t -> Option.t
val set_prev_fired : t -> Option.t -> unit
val next_fired : t -> Option.t
val set_next_fired : t -> Option.t -> unit
val set_interval : t -> Core.Core_private.Time_ns_alternate_sexp.Span.t option -> unit
val execution_context : t -> Execution_context.t
val callback : t -> unit -> unit
val set_at : t -> Core.Time_ns.t -> unit
val alarm : t -> Async_kernel__.Types.Job_or_event.t Timing_wheel.Alarm.t
val set_alarm : t -> Async_kernel__.Types.Job_or_event.t Timing_wheel.Alarm.t -> unit
module Fields : sig ... end
val sexp_of_t : event -> Ppx_sexp_conv_lib.Sexp.t
val invariant : event -> unit
val set_status : t -> Status.t -> unit
val set_status_if : is:Status.t -> t -> Status.t -> unit
val scheduled_at : t -> Core.Time_ns.t
val create_internal : 'a Async_kernel__.Types.Time_source.t1 -> at:Core.Time_ns.t -> interval:Core.Core_private.Time_ns_alternate_sexp.Span.t option -> callback:(unit -> unit) -> t
val add : 'a Async_kernel__.Types.Time_source.t1 -> t -> unit
val create_and_add : 'a Async_kernel__.Types.Time_source.t1 -> at:Core.Time_ns.t -> interval:Core.Core_private.Time_ns_alternate_sexp.Span.t option -> callback:(unit -> unit) -> t
val at : 'a Async_kernel__.Types.Time_source.t1 -> Core.Time_ns.t -> (unit -> unit) -> t
val after : 'a Async_kernel__.Types.Time_source.t1 -> Core.Core_private.Time_ns_alternate_sexp.Span.t -> (unit -> unit) -> t
val require_span_at_least_alarm_precision : 'a Async_kernel__.Types.Time_source.t1 -> Core.Core_private.Time_ns_alternate_sexp.Span.t -> unit
val at_intervals : ?start:Core.Time_ns.t -> 'a Async_kernel__.Types.Time_source.t1 -> Core.Core_private.Time_ns_alternate_sexp.Span.t -> (unit -> unit) -> t
module Abort_result : sig ... end
val abort : 'a Async_kernel__.Types.Time_source.t1 -> t -> Abort_result.t
val abort_if_possible : 'a Async_kernel__.Types.Time_source.t1 -> t -> unit
val abort_exn : 'a Async_kernel__.Types.Time_source.t1 -> t -> unit
val create : 'a Async_kernel__.Types.Time_source.t1 -> (unit -> unit) -> t
val is_scheduled : t -> bool
val schedule_at_internal : 'a Async_kernel__.Types.Time_source.t1 -> t -> Core.Time_ns.t -> interval:Core.Core_private.Time_ns_alternate_sexp.Span.t option -> unit Core.Or_error.t
val schedule_at : 'a Async_kernel__.Types.Time_source.t1 -> t -> Core.Time_ns.t -> unit Core.Or_error.t
val schedule_after : 'a Async_kernel__.Types.Time_source.t1 -> t -> Core.Core_private.Time_ns_alternate_sexp.Span.t -> unit Core.Or_error.t
val schedule_at_intervals' : 'a Async_kernel__.Types.Time_source.t1 -> t -> Core.Core_private.Time_ns_alternate_sexp.Span.t -> starting_at:Core.Time_ns.t -> unit Core.Or_error.t
val schedule_at_intervals : 'a Async_kernel__.Types.Time_source.t1 -> t -> Core.Core_private.Time_ns_alternate_sexp.Span.t -> unit Core.Or_error.t
val reschedule_at : 'a Async_kernel__.Types.Time_source.t1 -> t -> Core.Time_ns.t -> unit
val reschedule_after : 'a Async_kernel__.Types.Time_source.t1 -> t -> Core.Core_private.Time_ns_alternate_sexp.Span.t -> unit
OCaml

Innovation. Community. Security.