package async_kernel

  1. Overview
  2. Docs
package async_kernel
Legend:
Library
Module
Module type
Parameter
Class
Class type
val iter : Async_kernel__.Types.Event.t -> alarm: (([< `Read | `Set_and_create ], Async_kernel__.Types.Event.t, Async_kernel__.Types.Job_or_event.t Timing_wheel.Alarm.t) Fieldslib.Field.t_with_perm -> Async_kernel__.Types.Event.t -> Async_kernel__.Types.Job_or_event.t Timing_wheel.Alarm.t -> 'a) -> at: (([< `Read | `Set_and_create ], Async_kernel__.Types.Event.t, Core.Time_ns.t) Fieldslib.Field.t_with_perm -> Async_kernel__.Types.Event.t -> Core.Time_ns.t -> 'b) -> callback: (([< `Read | `Set_and_create ], Async_kernel__.Types.Event.t, unit -> unit) Fieldslib.Field.t_with_perm -> Async_kernel__.Types.Event.t -> (unit -> unit) -> 'c) -> execution_context: (([< `Read | `Set_and_create ], Async_kernel__.Types.Event.t, Execution_context.t) Fieldslib.Field.t_with_perm -> Async_kernel__.Types.Event.t -> Execution_context.t -> 'd) -> interval: (([< `Read | `Set_and_create ], Async_kernel__.Types.Event.t, Core.Core_private.Time_ns_alternate_sexp.Span.t option) Fieldslib.Field.t_with_perm -> Async_kernel__.Types.Event.t -> Core.Core_private.Time_ns_alternate_sexp.Span.t option -> 'e) -> next_fired: (([< `Read | `Set_and_create ], Async_kernel__.Types.Event.t, Async_kernel__.Types.Event.Option.t) Fieldslib.Field.t_with_perm -> Async_kernel__.Types.Event.t -> Async_kernel__.Types.Event.Option.t -> 'f) -> prev_fired: (([< `Read | `Set_and_create ], Async_kernel__.Types.Event.t, Async_kernel__.Types.Event.Option.t) Fieldslib.Field.t_with_perm -> Async_kernel__.Types.Event.t -> Async_kernel__.Types.Event.Option.t -> 'g) -> status: (([< `Read | `Set_and_create ], Async_kernel__.Types.Event.t, Async_kernel__.Types.Event.Status.t) Fieldslib.Field.t_with_perm -> Async_kernel__.Types.Event.t -> Async_kernel__.Types.Event.Status.t -> 'h) -> 'i
val fold : Async_kernel__.Types.Event.t -> init:'a -> alarm: ('b -> ([< `Read | `Set_and_create ], Async_kernel__.Types.Event.t, Async_kernel__.Types.Job_or_event.t Timing_wheel.Alarm.t) Fieldslib.Field.t_with_perm -> Async_kernel__.Types.Event.t -> Async_kernel__.Types.Job_or_event.t Timing_wheel.Alarm.t -> 'c) -> at: ('d -> ([< `Read | `Set_and_create ], Async_kernel__.Types.Event.t, Core.Time_ns.t) Fieldslib.Field.t_with_perm -> Async_kernel__.Types.Event.t -> Core.Time_ns.t -> 'e) -> callback: ('f -> ([< `Read | `Set_and_create ], Async_kernel__.Types.Event.t, unit -> unit) Fieldslib.Field.t_with_perm -> Async_kernel__.Types.Event.t -> (unit -> unit) -> 'g) -> execution_context: ('h -> ([< `Read | `Set_and_create ], Async_kernel__.Types.Event.t, Execution_context.t) Fieldslib.Field.t_with_perm -> Async_kernel__.Types.Event.t -> Execution_context.t -> 'i) -> interval: ('j -> ([< `Read | `Set_and_create ], Async_kernel__.Types.Event.t, Core.Core_private.Time_ns_alternate_sexp.Span.t option) Fieldslib.Field.t_with_perm -> Async_kernel__.Types.Event.t -> Core.Core_private.Time_ns_alternate_sexp.Span.t option -> 'k) -> next_fired: ('l -> ([< `Read | `Set_and_create ], Async_kernel__.Types.Event.t, Async_kernel__.Types.Event.Option.t) Fieldslib.Field.t_with_perm -> Async_kernel__.Types.Event.t -> Async_kernel__.Types.Event.Option.t -> 'm) -> prev_fired: ('n -> ([< `Read | `Set_and_create ], Async_kernel__.Types.Event.t, Async_kernel__.Types.Event.Option.t) Fieldslib.Field.t_with_perm -> Async_kernel__.Types.Event.t -> Async_kernel__.Types.Event.Option.t -> 'o) -> status: ('p -> ([< `Read | `Set_and_create ], Async_kernel__.Types.Event.t, Async_kernel__.Types.Event.Status.t) Fieldslib.Field.t_with_perm -> Async_kernel__.Types.Event.t -> Async_kernel__.Types.Event.Status.t -> 'q) -> 'r
val for_all : Async_kernel__.Types.Event.t -> alarm: (([< `Read | `Set_and_create ], Async_kernel__.Types.Event.t, Async_kernel__.Types.Job_or_event.t Timing_wheel.Alarm.t) Fieldslib.Field.t_with_perm -> Async_kernel__.Types.Event.t -> Async_kernel__.Types.Job_or_event.t Timing_wheel.Alarm.t -> bool) -> at: (([< `Read | `Set_and_create ], Async_kernel__.Types.Event.t, Core.Time_ns.t) Fieldslib.Field.t_with_perm -> Async_kernel__.Types.Event.t -> Core.Time_ns.t -> bool) -> callback: (([< `Read | `Set_and_create ], Async_kernel__.Types.Event.t, unit -> unit) Fieldslib.Field.t_with_perm -> Async_kernel__.Types.Event.t -> (unit -> unit) -> bool) -> execution_context: (([< `Read | `Set_and_create ], Async_kernel__.Types.Event.t, Execution_context.t) Fieldslib.Field.t_with_perm -> Async_kernel__.Types.Event.t -> Execution_context.t -> bool) -> interval: (([< `Read | `Set_and_create ], Async_kernel__.Types.Event.t, Core.Core_private.Time_ns_alternate_sexp.Span.t option) Fieldslib.Field.t_with_perm -> Async_kernel__.Types.Event.t -> Core.Core_private.Time_ns_alternate_sexp.Span.t option -> bool) -> next_fired: (([< `Read | `Set_and_create ], Async_kernel__.Types.Event.t, Async_kernel__.Types.Event.Option.t) Fieldslib.Field.t_with_perm -> Async_kernel__.Types.Event.t -> Async_kernel__.Types.Event.Option.t -> bool) -> prev_fired: (([< `Read | `Set_and_create ], Async_kernel__.Types.Event.t, Async_kernel__.Types.Event.Option.t) Fieldslib.Field.t_with_perm -> Async_kernel__.Types.Event.t -> Async_kernel__.Types.Event.Option.t -> bool) -> status: (([< `Read | `Set_and_create ], Async_kernel__.Types.Event.t, Async_kernel__.Types.Event.Status.t) Fieldslib.Field.t_with_perm -> Async_kernel__.Types.Event.t -> Async_kernel__.Types.Event.Status.t -> bool) -> bool
val exists : Async_kernel__.Types.Event.t -> alarm: (([< `Read | `Set_and_create ], Async_kernel__.Types.Event.t, Async_kernel__.Types.Job_or_event.t Timing_wheel.Alarm.t) Fieldslib.Field.t_with_perm -> Async_kernel__.Types.Event.t -> Async_kernel__.Types.Job_or_event.t Timing_wheel.Alarm.t -> bool) -> at: (([< `Read | `Set_and_create ], Async_kernel__.Types.Event.t, Core.Time_ns.t) Fieldslib.Field.t_with_perm -> Async_kernel__.Types.Event.t -> Core.Time_ns.t -> bool) -> callback: (([< `Read | `Set_and_create ], Async_kernel__.Types.Event.t, unit -> unit) Fieldslib.Field.t_with_perm -> Async_kernel__.Types.Event.t -> (unit -> unit) -> bool) -> execution_context: (([< `Read | `Set_and_create ], Async_kernel__.Types.Event.t, Execution_context.t) Fieldslib.Field.t_with_perm -> Async_kernel__.Types.Event.t -> Execution_context.t -> bool) -> interval: (([< `Read | `Set_and_create ], Async_kernel__.Types.Event.t, Core.Core_private.Time_ns_alternate_sexp.Span.t option) Fieldslib.Field.t_with_perm -> Async_kernel__.Types.Event.t -> Core.Core_private.Time_ns_alternate_sexp.Span.t option -> bool) -> next_fired: (([< `Read | `Set_and_create ], Async_kernel__.Types.Event.t, Async_kernel__.Types.Event.Option.t) Fieldslib.Field.t_with_perm -> Async_kernel__.Types.Event.t -> Async_kernel__.Types.Event.Option.t -> bool) -> prev_fired: (([< `Read | `Set_and_create ], Async_kernel__.Types.Event.t, Async_kernel__.Types.Event.Option.t) Fieldslib.Field.t_with_perm -> Async_kernel__.Types.Event.t -> Async_kernel__.Types.Event.Option.t -> bool) -> status: (([< `Read | `Set_and_create ], Async_kernel__.Types.Event.t, Async_kernel__.Types.Event.Status.t) Fieldslib.Field.t_with_perm -> Async_kernel__.Types.Event.t -> Async_kernel__.Types.Event.Status.t -> bool) -> bool
val to_list : Async_kernel__.Types.Event.t -> alarm: (([< `Read | `Set_and_create ], Async_kernel__.Types.Event.t, Async_kernel__.Types.Job_or_event.t Timing_wheel.Alarm.t) Fieldslib.Field.t_with_perm -> Async_kernel__.Types.Event.t -> Async_kernel__.Types.Job_or_event.t Timing_wheel.Alarm.t -> 'a) -> at: (([< `Read | `Set_and_create ], Async_kernel__.Types.Event.t, Core.Time_ns.t) Fieldslib.Field.t_with_perm -> Async_kernel__.Types.Event.t -> Core.Time_ns.t -> 'b) -> callback: (([< `Read | `Set_and_create ], Async_kernel__.Types.Event.t, unit -> unit) Fieldslib.Field.t_with_perm -> Async_kernel__.Types.Event.t -> (unit -> unit) -> 'c) -> execution_context: (([< `Read | `Set_and_create ], Async_kernel__.Types.Event.t, Execution_context.t) Fieldslib.Field.t_with_perm -> Async_kernel__.Types.Event.t -> Execution_context.t -> 'd) -> interval: (([< `Read | `Set_and_create ], Async_kernel__.Types.Event.t, Core.Core_private.Time_ns_alternate_sexp.Span.t option) Fieldslib.Field.t_with_perm -> Async_kernel__.Types.Event.t -> Core.Core_private.Time_ns_alternate_sexp.Span.t option -> 'e) -> next_fired: (([< `Read | `Set_and_create ], Async_kernel__.Types.Event.t, Async_kernel__.Types.Event.Option.t) Fieldslib.Field.t_with_perm -> Async_kernel__.Types.Event.t -> Async_kernel__.Types.Event.Option.t -> 'f) -> prev_fired: (([< `Read | `Set_and_create ], Async_kernel__.Types.Event.t, Async_kernel__.Types.Event.Option.t) Fieldslib.Field.t_with_perm -> Async_kernel__.Types.Event.t -> Async_kernel__.Types.Event.Option.t -> 'g) -> status: (([< `Read | `Set_and_create ], Async_kernel__.Types.Event.t, Async_kernel__.Types.Event.Status.t) Fieldslib.Field.t_with_perm -> Async_kernel__.Types.Event.t -> Async_kernel__.Types.Event.Status.t -> 'h) -> 'i list
val map : Async_kernel__.Types.Event.t -> alarm: (([< `Read | `Set_and_create ], Async_kernel__.Types.Event.t, Async_kernel__.Types.Job_or_event.t Timing_wheel.Alarm.t) Fieldslib.Field.t_with_perm -> Async_kernel__.Types.Event.t -> Async_kernel__.Types.Job_or_event.t Timing_wheel.Alarm.t -> Async_kernel__.Types.Job_or_event.t Timing_wheel.Alarm.t) -> at: (([< `Read | `Set_and_create ], Async_kernel__.Types.Event.t, Core.Time_ns.t) Fieldslib.Field.t_with_perm -> Async_kernel__.Types.Event.t -> Core.Time_ns.t -> Core.Time_ns.t) -> callback: (([< `Read | `Set_and_create ], Async_kernel__.Types.Event.t, unit -> unit) Fieldslib.Field.t_with_perm -> Async_kernel__.Types.Event.t -> (unit -> unit) -> unit -> unit) -> execution_context: (([< `Read | `Set_and_create ], Async_kernel__.Types.Event.t, Execution_context.t) Fieldslib.Field.t_with_perm -> Async_kernel__.Types.Event.t -> Execution_context.t -> Execution_context.t) -> interval: (([< `Read | `Set_and_create ], Async_kernel__.Types.Event.t, Core.Core_private.Time_ns_alternate_sexp.Span.t option) Fieldslib.Field.t_with_perm -> Async_kernel__.Types.Event.t -> Core.Core_private.Time_ns_alternate_sexp.Span.t option -> Core.Core_private.Time_ns_alternate_sexp.Span.t option) -> next_fired: (([< `Read | `Set_and_create ], Async_kernel__.Types.Event.t, Async_kernel__.Types.Event.Option.t) Fieldslib.Field.t_with_perm -> Async_kernel__.Types.Event.t -> Async_kernel__.Types.Event.Option.t -> Async_kernel__.Types.Event.Option.t) -> prev_fired: (([< `Read | `Set_and_create ], Async_kernel__.Types.Event.t, Async_kernel__.Types.Event.Option.t) Fieldslib.Field.t_with_perm -> Async_kernel__.Types.Event.t -> Async_kernel__.Types.Event.Option.t -> Async_kernel__.Types.Event.Option.t) -> status: (([< `Read | `Set_and_create ], Async_kernel__.Types.Event.t, Async_kernel__.Types.Event.Status.t) Fieldslib.Field.t_with_perm -> Async_kernel__.Types.Event.t -> Async_kernel__.Types.Event.Status.t -> Async_kernel__.Types.Event.Status.t) -> Async_kernel__.Types.Event.t
val set_all_mutable_fields : Async_kernel__.Types.Event.t -> alarm:Async_kernel__.Types.Job_or_event.t Timing_wheel.Alarm.t -> at:Core.Time_ns.t -> interval:Core.Core_private.Time_ns_alternate_sexp.Span.t option -> next_fired:Async_kernel__.Types.Event.Option.t -> prev_fired:Async_kernel__.Types.Event.Option.t -> status:Async_kernel__.Types.Event.Status.t -> unit