include sig ... end
val sexp_of_t : t ‑> Sexplib.Sexp.t
val at : [> Core_kernel.read ] Async_kernel__Synchronous_time_source0.T1.t ‑> Async_kernel__.Import.Time_ns.t ‑> Async_kernel__Synchronous_time_source0.callback ‑> t
These are like the corresponding run_*
functions, except they return an event that
one can later abort
.
val at_intervals : [> Core_kernel.read ] Async_kernel__Synchronous_time_source0.T1.t ‑> Async_kernel__.Import.Time_ns.Span.t ‑> Async_kernel__Synchronous_time_source0.callback ‑> 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.