async_kernel v0.14.0 · OCaml Package

val names : string list

val status : 
  ([< `Read | `Set_and_create ],
    Async_kernel__.Types.Event.t,
    Async_kernel__.Types.Event.Status.t)
    Fieldslib.Field.t_with_perm

val next_fired : 
  ([< `Read | `Set_and_create ],
    Async_kernel__.Types.Event.t,
    Async_kernel__.Types.Event.t)
    Fieldslib.Field.t_with_perm

val interval : 
  ([< `Read | `Set_and_create ],
    Async_kernel__.Types.Event.t,
    Core_kernel.Core_kernel_private.Time_ns_alternate_sexp.Span.t option)
    Fieldslib.Field.t_with_perm

val execution_context : 
  ([< `Read | `Set_and_create ],
    Async_kernel__.Types.Event.t,
    Execution_context.t)
    Fieldslib.Field.t_with_perm

val callback : 
  ([< `Read | `Set_and_create ], Async_kernel__.Types.Event.t, unit -> unit)
    Fieldslib.Field.t_with_perm

val at : 
  ([< `Read | `Set_and_create ],
    Async_kernel__.Types.Event.t,
    Core_kernel.Time_ns.t)
    Fieldslib.Field.t_with_perm

val 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

val make_creator : 
  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 ->
      'a ->
      ('b -> Async_kernel__.Types.Job_or_event.t Timing_wheel.Alarm.t) * 'c) ->
  at:
    (([< `Read | `Set_and_create ],
       Async_kernel__.Types.Event.t,
       Core_kernel.Time_ns.t)
       Fieldslib.Field.t_with_perm ->
      'c ->
      ('b -> Core_kernel.Time_ns.t) * 'd) ->
  callback:
    (([< `Read | `Set_and_create ], Async_kernel__.Types.Event.t, unit -> unit)
       Fieldslib.Field.t_with_perm ->
      'd ->
      ('b -> unit -> unit) * 'e) ->
  execution_context:
    (([< `Read | `Set_and_create ],
       Async_kernel__.Types.Event.t,
       Execution_context.t)
       Fieldslib.Field.t_with_perm ->
      'e ->
      ('b -> Execution_context.t) * 'f) ->
  interval:
    (([< `Read | `Set_and_create ],
       Async_kernel__.Types.Event.t,
       Core_kernel.Core_kernel_private.Time_ns_alternate_sexp.Span.t option)
       Fieldslib.Field.t_with_perm ->
      'f ->
      ('b ->
      Core_kernel.Core_kernel_private.Time_ns_alternate_sexp.Span.t option)
      * 'g) ->
  next_fired:
    (([< `Read | `Set_and_create ],
       Async_kernel__.Types.Event.t,
       Async_kernel__.Types.Event.t)
       Fieldslib.Field.t_with_perm ->
      'g ->
      ('b -> Async_kernel__.Types.Event.t) * 'h) ->
  status:
    (([< `Read | `Set_and_create ],
       Async_kernel__.Types.Event.t,
       Async_kernel__.Types.Event.Status.t)
       Fieldslib.Field.t_with_perm ->
      'h ->
      ('b -> Async_kernel__.Types.Event.Status.t) * 'i) ->
  'a ->
  ('b -> Async_kernel__.Types.Event.t) * 'i

val create : 
  alarm:Async_kernel__.Types.Job_or_event.t Timing_wheel.Alarm.t ->
  at:Core_kernel.Time_ns.t ->
  callback:(unit -> unit) ->
  execution_context:Execution_context.t ->
  interval:Core_kernel.Core_kernel_private.Time_ns_alternate_sexp.Span.t option ->
  next_fired:Async_kernel__.Types.Event.t ->
  status:Async_kernel__.Types.Event.Status.t ->
  Async_kernel__.Types.Event.t

val map : 
  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.Job_or_event.t Timing_wheel.Alarm.t) ->
  at:
    (([< `Read | `Set_and_create ],
       Async_kernel__.Types.Event.t,
       Core_kernel.Time_ns.t)
       Fieldslib.Field.t_with_perm ->
      Core_kernel.Time_ns.t) ->
  callback:
    (([< `Read | `Set_and_create ], Async_kernel__.Types.Event.t, unit -> unit)
       Fieldslib.Field.t_with_perm ->
      unit ->
      unit) ->
  execution_context:
    (([< `Read | `Set_and_create ],
       Async_kernel__.Types.Event.t,
       Execution_context.t)
       Fieldslib.Field.t_with_perm ->
      Execution_context.t) ->
  interval:
    (([< `Read | `Set_and_create ],
       Async_kernel__.Types.Event.t,
       Core_kernel.Core_kernel_private.Time_ns_alternate_sexp.Span.t option)
       Fieldslib.Field.t_with_perm ->
      Core_kernel.Core_kernel_private.Time_ns_alternate_sexp.Span.t option) ->
  next_fired:
    (([< `Read | `Set_and_create ],
       Async_kernel__.Types.Event.t,
       Async_kernel__.Types.Event.t)
       Fieldslib.Field.t_with_perm ->
      Async_kernel__.Types.Event.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.Status.t) ->
  Async_kernel__.Types.Event.t

val iter : 
  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 ->
      unit) ->
  at:
    (([< `Read | `Set_and_create ],
       Async_kernel__.Types.Event.t,
       Core_kernel.Time_ns.t)
       Fieldslib.Field.t_with_perm ->
      unit) ->
  callback:
    (([< `Read | `Set_and_create ], Async_kernel__.Types.Event.t, unit -> unit)
       Fieldslib.Field.t_with_perm ->
      unit) ->
  execution_context:
    (([< `Read | `Set_and_create ],
       Async_kernel__.Types.Event.t,
       Execution_context.t)
       Fieldslib.Field.t_with_perm ->
      unit) ->
  interval:
    (([< `Read | `Set_and_create ],
       Async_kernel__.Types.Event.t,
       Core_kernel.Core_kernel_private.Time_ns_alternate_sexp.Span.t option)
       Fieldslib.Field.t_with_perm ->
      unit) ->
  next_fired:
    (([< `Read | `Set_and_create ],
       Async_kernel__.Types.Event.t,
       Async_kernel__.Types.Event.t)
       Fieldslib.Field.t_with_perm ->
      unit) ->
  status:
    (([< `Read | `Set_and_create ],
       Async_kernel__.Types.Event.t,
       Async_kernel__.Types.Event.Status.t)
       Fieldslib.Field.t_with_perm ->
      unit) ->
  unit

val fold : 
  init:'a ->
  alarm:
    ('a ->
      ([< `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 ->
      'b) ->
  at:
    ('b ->
      ([< `Read | `Set_and_create ],
        Async_kernel__.Types.Event.t,
        Core_kernel.Time_ns.t)
        Fieldslib.Field.t_with_perm ->
      'c) ->
  callback:
    ('c ->
      ([< `Read | `Set_and_create ],
        Async_kernel__.Types.Event.t,
        unit ->
        unit)
        Fieldslib.Field.t_with_perm ->
      'd) ->
  execution_context:
    ('d ->
      ([< `Read | `Set_and_create ],
        Async_kernel__.Types.Event.t,
        Execution_context.t)
        Fieldslib.Field.t_with_perm ->
      'e) ->
  interval:
    ('e ->
      ([< `Read | `Set_and_create ],
        Async_kernel__.Types.Event.t,
        Core_kernel.Core_kernel_private.Time_ns_alternate_sexp.Span.t option)
        Fieldslib.Field.t_with_perm ->
      'f) ->
  next_fired:
    ('f ->
      ([< `Read | `Set_and_create ],
        Async_kernel__.Types.Event.t,
        Async_kernel__.Types.Event.t)
        Fieldslib.Field.t_with_perm ->
      'g) ->
  status:
    ('g ->
      ([< `Read | `Set_and_create ],
        Async_kernel__.Types.Event.t,
        Async_kernel__.Types.Event.Status.t)
        Fieldslib.Field.t_with_perm ->
      'h) ->
  'h

val map_poly : 
  ([< `Read | `Set_and_create ], Async_kernel__.Types.Event.t, 'a)
    Fieldslib.Field.user ->
  'a list

val for_all : 
  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 ->
      bool) ->
  at:
    (([< `Read | `Set_and_create ],
       Async_kernel__.Types.Event.t,
       Core_kernel.Time_ns.t)
       Fieldslib.Field.t_with_perm ->
      bool) ->
  callback:
    (([< `Read | `Set_and_create ], Async_kernel__.Types.Event.t, unit -> unit)
       Fieldslib.Field.t_with_perm ->
      bool) ->
  execution_context:
    (([< `Read | `Set_and_create ],
       Async_kernel__.Types.Event.t,
       Execution_context.t)
       Fieldslib.Field.t_with_perm ->
      bool) ->
  interval:
    (([< `Read | `Set_and_create ],
       Async_kernel__.Types.Event.t,
       Core_kernel.Core_kernel_private.Time_ns_alternate_sexp.Span.t option)
       Fieldslib.Field.t_with_perm ->
      bool) ->
  next_fired:
    (([< `Read | `Set_and_create ],
       Async_kernel__.Types.Event.t,
       Async_kernel__.Types.Event.t)
       Fieldslib.Field.t_with_perm ->
      bool) ->
  status:
    (([< `Read | `Set_and_create ],
       Async_kernel__.Types.Event.t,
       Async_kernel__.Types.Event.Status.t)
       Fieldslib.Field.t_with_perm ->
      bool) ->
  bool

val exists : 
  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 ->
      bool) ->
  at:
    (([< `Read | `Set_and_create ],
       Async_kernel__.Types.Event.t,
       Core_kernel.Time_ns.t)
       Fieldslib.Field.t_with_perm ->
      bool) ->
  callback:
    (([< `Read | `Set_and_create ], Async_kernel__.Types.Event.t, unit -> unit)
       Fieldslib.Field.t_with_perm ->
      bool) ->
  execution_context:
    (([< `Read | `Set_and_create ],
       Async_kernel__.Types.Event.t,
       Execution_context.t)
       Fieldslib.Field.t_with_perm ->
      bool) ->
  interval:
    (([< `Read | `Set_and_create ],
       Async_kernel__.Types.Event.t,
       Core_kernel.Core_kernel_private.Time_ns_alternate_sexp.Span.t option)
       Fieldslib.Field.t_with_perm ->
      bool) ->
  next_fired:
    (([< `Read | `Set_and_create ],
       Async_kernel__.Types.Event.t,
       Async_kernel__.Types.Event.t)
       Fieldslib.Field.t_with_perm ->
      bool) ->
  status:
    (([< `Read | `Set_and_create ],
       Async_kernel__.Types.Event.t,
       Async_kernel__.Types.Event.Status.t)
       Fieldslib.Field.t_with_perm ->
      bool) ->
  bool

val to_list : 
  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 ->
      'a) ->
  at:
    (([< `Read | `Set_and_create ],
       Async_kernel__.Types.Event.t,
       Core_kernel.Time_ns.t)
       Fieldslib.Field.t_with_perm ->
      'a) ->
  callback:
    (([< `Read | `Set_and_create ], Async_kernel__.Types.Event.t, unit -> unit)
       Fieldslib.Field.t_with_perm ->
      'a) ->
  execution_context:
    (([< `Read | `Set_and_create ],
       Async_kernel__.Types.Event.t,
       Execution_context.t)
       Fieldslib.Field.t_with_perm ->
      'a) ->
  interval:
    (([< `Read | `Set_and_create ],
       Async_kernel__.Types.Event.t,
       Core_kernel.Core_kernel_private.Time_ns_alternate_sexp.Span.t option)
       Fieldslib.Field.t_with_perm ->
      'a) ->
  next_fired:
    (([< `Read | `Set_and_create ],
       Async_kernel__.Types.Event.t,
       Async_kernel__.Types.Event.t)
       Fieldslib.Field.t_with_perm ->
      'a) ->
  status:
    (([< `Read | `Set_and_create ],
       Async_kernel__.Types.Event.t,
       Async_kernel__.Types.Event.Status.t)
       Fieldslib.Field.t_with_perm ->
      'a) ->
  'a list

module Direct : sig ... end

package async_kernel