package async_kernel

  1. Overview
  2. Docs
Legend:
Library
Module
Module type
Parameter
Class
Class type
type t
include sig ... end
val sexp_of_t : t -> Sexplib.Sexp.t
include Core_kernel.Invariant.S with type t := t
val invariant : t -> unit
val at : [> Core_kernel.read ] Async_kernel__.Synchronous_time_source0.T1.t -> Base__.Int63_backends.Dynamic.t -> (unit -> unit) -> t

These are like the corresponding run_* functions, except they return an event that one can later abort.

val after : [> Core_kernel.read ] Async_kernel__.Synchronous_time_source0.T1.t -> Core_kernel.Core_kernel_private.Time_ns_alternate_sexp.Span.t -> (unit -> unit) -> t
val at_intervals : [> Core_kernel.read ] Async_kernel__.Synchronous_time_source0.T1.t -> Core_kernel.Core_kernel_private.Time_ns_alternate_sexp.Span.t -> (unit -> unit) -> t
val abort : [> Core_kernel.read ] Async_kernel__.Synchronous_time_source0.T1.t -> t -> unit Core_kernel.Or_error.t

abort t aborts the event t, if possible, and returns Ok if the event was aborted, or Error with the reason it could not be aborted.