async_unix v0.9.1 · OCaml Package

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

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

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

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

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

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

val set_all_mutable_fields : 
  'a t ->
  bytes_received_at_now_minus_maximum_age:Core.Int63.t ->
  bytes_seen:Core.Int63.t ->
  too_old:unit Async_unix.Import.Ivar.t ->
  unit

package async_unix