async_unix v0.9.0 · OCaml Package

val names : string list

val too_old : 
  ([< `Read | `Set_and_create ], 'a t, unit Async_unix.Import.Ivar.t)
    Fieldslib.Field.t_with_perm

val bytes_seen : 
  ([< `Read | `Set_and_create ], 'a t, Core.Int63.t)
    Fieldslib.Field.t_with_perm

val times_received_queue : 
  ([< `Read | `Set_and_create ], 'a t, Core.Time_ns.t Core.Queue.t)
    Fieldslib.Field.t_with_perm

val bytes_received_queue : 
  ([< `Read | `Set_and_create ], 'a t, Core.Int63.t Core.Queue.t)
    Fieldslib.Field.t_with_perm

val bytes_received_at_now_minus_maximum_age : 
  ([< `Read | `Set_and_create ], 'a t, Core.Int63.t)
    Fieldslib.Field.t_with_perm

val maximum_age : 
  ([< `Read | `Set_and_create ], 'a t, Core.Time_ns.Span.t)
    Fieldslib.Field.t_with_perm

val writer : 
  ([< `Read | `Set_and_create ], 'a t, 'a) Fieldslib.Field.t_with_perm

val make_creator : 
  writer:
    (([< `Read | `Set_and_create ], 'a t, 'a) Fieldslib.Field.t_with_perm ->
      'b ->
      ('c -> 'd) * 'e) ->
  maximum_age:
    (([< `Read | `Set_and_create ], 'f t, Core.Time_ns.Span.t)
       Fieldslib.Field.t_with_perm ->
      'e ->
      ('c -> Core.Time_ns.Span.t) * 'g) ->
  bytes_received_at_now_minus_maximum_age:
    (([< `Read | `Set_and_create ], 'h t, Core.Int63.t)
       Fieldslib.Field.t_with_perm ->
      'g ->
      ('c -> Core.Int63.t) * 'i) ->
  bytes_received_queue:
    (([< `Read | `Set_and_create ], 'j t, Core.Int63.t Core.Queue.t)
       Fieldslib.Field.t_with_perm ->
      'i ->
      ('c -> Core.Int63.t Core.Queue.t) * 'k) ->
  times_received_queue:
    (([< `Read | `Set_and_create ], 'l t, Core.Time_ns.t Core.Queue.t)
       Fieldslib.Field.t_with_perm ->
      'k ->
      ('c -> Core.Time_ns.t Core.Queue.t) * 'm) ->
  bytes_seen:
    (([< `Read | `Set_and_create ], 'n t, Core.Int63.t)
       Fieldslib.Field.t_with_perm ->
      'm ->
      ('c -> Core.Int63.t) * 'o) ->
  too_old:
    (([< `Read | `Set_and_create ], 'p t, unit Async_unix.Import.Ivar.t)
       Fieldslib.Field.t_with_perm ->
      'o ->
      ('c -> unit Async_unix.Import.Ivar.t) * 'q) ->
  'b ->
  ('c -> 'd t) * 'q

val create : 
  writer:'a ->
  maximum_age:Core.Time_ns.Span.t ->
  bytes_received_at_now_minus_maximum_age:Core.Int63.t ->
  bytes_received_queue:Core.Int63.t Core.Queue.t ->
  times_received_queue:Core.Time_ns.t Core.Queue.t ->
  bytes_seen:Core.Int63.t ->
  too_old:unit Async_unix.Import.Ivar.t ->
  'a t

val map : 
  writer:
    (([< `Read | `Set_and_create ], 'a t, 'a) Fieldslib.Field.t_with_perm ->
      'b) ->
  maximum_age:
    (([< `Read | `Set_and_create ], 'c t, Core.Time_ns.Span.t)
       Fieldslib.Field.t_with_perm ->
      Core.Time_ns.Span.t) ->
  bytes_received_at_now_minus_maximum_age:
    (([< `Read | `Set_and_create ], 'd t, Core.Int63.t)
       Fieldslib.Field.t_with_perm ->
      Core.Int63.t) ->
  bytes_received_queue:
    (([< `Read | `Set_and_create ], 'e t, Core.Int63.t Core.Queue.t)
       Fieldslib.Field.t_with_perm ->
      Core.Int63.t Core.Queue.t) ->
  times_received_queue:
    (([< `Read | `Set_and_create ], 'f t, Core.Time_ns.t Core.Queue.t)
       Fieldslib.Field.t_with_perm ->
      Core.Time_ns.t Core.Queue.t) ->
  bytes_seen:
    (([< `Read | `Set_and_create ], 'g t, Core.Int63.t)
       Fieldslib.Field.t_with_perm ->
      Core.Int63.t) ->
  too_old:
    (([< `Read | `Set_and_create ], 'h t, unit Async_unix.Import.Ivar.t)
       Fieldslib.Field.t_with_perm ->
      unit Async_unix.Import.Ivar.t) ->
  'b t

val iter : 
  writer:
    (([< `Read | `Set_and_create ], 'a t, 'a) Fieldslib.Field.t_with_perm ->
      unit) ->
  maximum_age:
    (([< `Read | `Set_and_create ], 'b t, Core.Time_ns.Span.t)
       Fieldslib.Field.t_with_perm ->
      unit) ->
  bytes_received_at_now_minus_maximum_age:
    (([< `Read | `Set_and_create ], 'c t, Core.Int63.t)
       Fieldslib.Field.t_with_perm ->
      unit) ->
  bytes_received_queue:
    (([< `Read | `Set_and_create ], 'd t, Core.Int63.t Core.Queue.t)
       Fieldslib.Field.t_with_perm ->
      unit) ->
  times_received_queue:
    (([< `Read | `Set_and_create ], 'e t, Core.Time_ns.t Core.Queue.t)
       Fieldslib.Field.t_with_perm ->
      unit) ->
  bytes_seen:
    (([< `Read | `Set_and_create ], 'f t, Core.Int63.t)
       Fieldslib.Field.t_with_perm ->
      unit) ->
  too_old:
    (([< `Read | `Set_and_create ], 'g t, unit Async_unix.Import.Ivar.t)
       Fieldslib.Field.t_with_perm ->
      unit) ->
  unit

val fold : 
  init:'a ->
  writer:
    ('a ->
      ([< `Read | `Set_and_create ], 'b t, 'b) Fieldslib.Field.t_with_perm ->
      'c) ->
  maximum_age:
    ('c ->
      ([< `Read | `Set_and_create ], 'd t, Core.Time_ns.Span.t)
        Fieldslib.Field.t_with_perm ->
      'e) ->
  bytes_received_at_now_minus_maximum_age:
    ('e ->
      ([< `Read | `Set_and_create ], 'f t, Core.Int63.t)
        Fieldslib.Field.t_with_perm ->
      'g) ->
  bytes_received_queue:
    ('g ->
      ([< `Read | `Set_and_create ], 'h t, Core.Int63.t Core.Queue.t)
        Fieldslib.Field.t_with_perm ->
      'i) ->
  times_received_queue:
    ('i ->
      ([< `Read | `Set_and_create ], 'j t, Core.Time_ns.t Core.Queue.t)
        Fieldslib.Field.t_with_perm ->
      'k) ->
  bytes_seen:
    ('k ->
      ([< `Read | `Set_and_create ], 'l t, Core.Int63.t)
        Fieldslib.Field.t_with_perm ->
      'm) ->
  too_old:
    ('m ->
      ([< `Read | `Set_and_create ], 'n t, unit Async_unix.Import.Ivar.t)
        Fieldslib.Field.t_with_perm ->
      'o) ->
  'o

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

val for_all : 
  writer:
    (([< `Read | `Set_and_create ], 'a t, 'a) Fieldslib.Field.t_with_perm ->
      bool) ->
  maximum_age:
    (([< `Read | `Set_and_create ], 'b t, Core.Time_ns.Span.t)
       Fieldslib.Field.t_with_perm ->
      bool) ->
  bytes_received_at_now_minus_maximum_age:
    (([< `Read | `Set_and_create ], 'c t, Core.Int63.t)
       Fieldslib.Field.t_with_perm ->
      bool) ->
  bytes_received_queue:
    (([< `Read | `Set_and_create ], 'd t, Core.Int63.t Core.Queue.t)
       Fieldslib.Field.t_with_perm ->
      bool) ->
  times_received_queue:
    (([< `Read | `Set_and_create ], 'e t, Core.Time_ns.t Core.Queue.t)
       Fieldslib.Field.t_with_perm ->
      bool) ->
  bytes_seen:
    (([< `Read | `Set_and_create ], 'f t, Core.Int63.t)
       Fieldslib.Field.t_with_perm ->
      bool) ->
  too_old:
    (([< `Read | `Set_and_create ], 'g t, unit Async_unix.Import.Ivar.t)
       Fieldslib.Field.t_with_perm ->
      bool) ->
  bool

val exists : 
  writer:
    (([< `Read | `Set_and_create ], 'a t, 'a) Fieldslib.Field.t_with_perm ->
      bool) ->
  maximum_age:
    (([< `Read | `Set_and_create ], 'b t, Core.Time_ns.Span.t)
       Fieldslib.Field.t_with_perm ->
      bool) ->
  bytes_received_at_now_minus_maximum_age:
    (([< `Read | `Set_and_create ], 'c t, Core.Int63.t)
       Fieldslib.Field.t_with_perm ->
      bool) ->
  bytes_received_queue:
    (([< `Read | `Set_and_create ], 'd t, Core.Int63.t Core.Queue.t)
       Fieldslib.Field.t_with_perm ->
      bool) ->
  times_received_queue:
    (([< `Read | `Set_and_create ], 'e t, Core.Time_ns.t Core.Queue.t)
       Fieldslib.Field.t_with_perm ->
      bool) ->
  bytes_seen:
    (([< `Read | `Set_and_create ], 'f t, Core.Int63.t)
       Fieldslib.Field.t_with_perm ->
      bool) ->
  too_old:
    (([< `Read | `Set_and_create ], 'g t, unit Async_unix.Import.Ivar.t)
       Fieldslib.Field.t_with_perm ->
      bool) ->
  bool

val to_list : 
  writer:
    (([< `Read | `Set_and_create ], 'a t, 'a) Fieldslib.Field.t_with_perm ->
      'b) ->
  maximum_age:
    (([< `Read | `Set_and_create ], 'c t, Core.Time_ns.Span.t)
       Fieldslib.Field.t_with_perm ->
      'b) ->
  bytes_received_at_now_minus_maximum_age:
    (([< `Read | `Set_and_create ], 'd t, Core.Int63.t)
       Fieldslib.Field.t_with_perm ->
      'b) ->
  bytes_received_queue:
    (([< `Read | `Set_and_create ], 'e t, Core.Int63.t Core.Queue.t)
       Fieldslib.Field.t_with_perm ->
      'b) ->
  times_received_queue:
    (([< `Read | `Set_and_create ], 'f t, Core.Time_ns.t Core.Queue.t)
       Fieldslib.Field.t_with_perm ->
      'b) ->
  bytes_seen:
    (([< `Read | `Set_and_create ], 'g t, Core.Int63.t)
       Fieldslib.Field.t_with_perm ->
      'b) ->
  too_old:
    (([< `Read | `Set_and_create ], 'h t, unit Async_unix.Import.Ivar.t)
       Fieldslib.Field.t_with_perm ->
      'b) ->
  'b list

module Direct : sig ... end

package async_unix