Module `Async_kernel__Time_source.Event`

type ('a, 'h) t

val sexp_of_t : ('a -> Ppx_sexp_conv_lib.Sexp.t) -> ('h -> Ppx_sexp_conv_lib.Sexp.t) -> ('a, 'h) t -> Ppx_sexp_conv_lib.Sexp.t

type t_unit = (unit, unit) t

val sexp_of_t_unit : t_unit -> Ppx_sexp_conv_lib.Sexp.t

include Core_kernel.Invariant.S2 with type ('a, 'b) t := ('a, 'b) t

type ('a, 'b) t

val invariant : 'a Base__.Invariant_intf.inv -> 'b Base__.Invariant_intf.inv -> ('a, 'b) t Base__.Invariant_intf.inv

val scheduled_at : (_, _) t -> Async_kernel__.Import.Time_ns.t

module Status : sig ... end

val status : ('a, 'h) t -> ('a, 'h) Status.t
val run_at : [> Core_kernel.read ] T1.t -> Async_kernel__.Import.Time_ns.t -> ('z -> 'h) -> 'z -> (_, 'h) t
val run_after : [> Core_kernel.read ] T1.t -> Async_kernel__.Import.Time_ns.Span.t -> ('z -> 'h) -> 'z -> (_, 'h) t

module Abort_result : sig ... end

val abort : ('a, 'h) t -> 'a -> ('a, 'h) Abort_result.t
val abort_exn : ('a, 'h) t -> 'a -> unit
val abort_if_possible : ('a, _) t -> 'a -> unit

module Fired : sig ... end

val fired : ('a, 'h) t -> ('a, 'h) Fired.t Async_kernel__.Time_source_intf.Deferred.t

module Reschedule_result : sig ... end

val reschedule_at : ('a, 'h) t -> Async_kernel__.Import.Time_ns.t -> ('a, 'h) Reschedule_result.t
val reschedule_after : ('a, 'h) t -> Async_kernel__.Import.Time_ns.Span.t -> ('a, 'h) Reschedule_result.t
val at : [> Core_kernel.read ] T1.t -> Async_kernel__.Import.Time_ns.t -> (_, unit) t
val after : [> Core_kernel.read ] T1.t -> Async_kernel__.Import.Time_ns.Span.t -> (_, unit) t