package async_unix

  1. Overview
  2. Docs
package async_unix
Legend:
Library
Module
Module type
Parameter
Class
Class type
val names : string list
val line_ending : ([< `Read | `Set_and_create ], t, Line_ending.t) Fieldslib.Field.t_with_perm
val open_flags : ([< `Read | `Set_and_create ], t, open_flags Async_unix.Import.Deferred.t) Fieldslib.Field.t_with_perm
val raise_when_consumer_leaves : ([< `Read | `Set_and_create ], t, bool) Fieldslib.Field.t_with_perm
val consumer_left : ([< `Read | `Set_and_create ], t, unit Async_unix.Import.Ivar.t) Fieldslib.Field.t_with_perm
val check_buffer_age : ([< `Read | `Set_and_create ], t, t Core.sexp_opaque Check_buffer_age'.t Core.Bag.Elt.t option) Fieldslib.Field.t_with_perm
val flush_at_shutdown_elt : ([< `Read | `Set_and_create ], t, t Core.sexp_opaque Core.Bag.Elt.t option) Fieldslib.Field.t_with_perm
val producers_to_flush_at_close : ([< `Read | `Set_and_create ], t, (unit -> unit Async_unix.Import.Deferred.t) Core.Bag.t) Fieldslib.Field.t_with_perm
val close_started : ([< `Read | `Set_and_create ], t, unit Async_unix.Import.Ivar.t) Fieldslib.Field.t_with_perm
val close_finished : ([< `Read | `Set_and_create ], t, unit Async_unix.Import.Ivar.t) Fieldslib.Field.t_with_perm
val close_state : ([< `Read | `Set_and_create ], t, [ `Closed | `Closed_and_flushing | `Open ]) Fieldslib.Field.t_with_perm
val back : ([< `Read | `Set_and_create ], t, int) Fieldslib.Field.t_with_perm
val scheduled_back : ([< `Read | `Set_and_create ], t, int) Fieldslib.Field.t_with_perm
val buf : ([< `Read | `Set_and_create ], t, Core.Bigstring.t Core.sexp_opaque) Fieldslib.Field.t_with_perm
val scheduled_bytes : ([< `Read | `Set_and_create ], t, int) Fieldslib.Field.t_with_perm
val scheduled : ([< `Read | `Set_and_create ], t, Scheduled.t Core.sexp_opaque) Fieldslib.Field.t_with_perm
val bytes_written : ([< `Read | `Set_and_create ], t, Core.Int63.t) Fieldslib.Field.t_with_perm
val bytes_received : ([< `Read | `Set_and_create ], t, Core.Int63.t) Fieldslib.Field.t_with_perm
val syscall : ([< `Read | `Set_and_create ], t, [ `Per_cycle | `Periodic of Core.Time.Span.t ]) Fieldslib.Field.t_with_perm
val background_writer_stopped : ([< `Read | `Set_and_create ], t, unit Async_unix.Import.Ivar.t) Fieldslib.Field.t_with_perm
val background_writer_state : ([< `Read | `Set_and_create ], t, [ `Not_running | `Running | `Stopped_permanently ]) Fieldslib.Field.t_with_perm
val inner_monitor : ([< `Read | `Set_and_create ], t, Async_unix.Import.Monitor.t) Fieldslib.Field.t_with_perm
val monitor : ([< `Read | `Set_and_create ], t, Async_unix.Import.Monitor.t) Fieldslib.Field.t_with_perm
val fd : ([< `Read | `Set_and_create ], t, Fd.t) Fieldslib.Field.t_with_perm
val id : ([< `Read | `Set_and_create ], t, Id.t) Fieldslib.Field.t_with_perm
val make_creator : id: (([< `Read | `Set_and_create ], t, Id.t) Fieldslib.Field.t_with_perm -> 'a -> ('b -> Id.t) * 'c) -> fd: (([< `Read | `Set_and_create ], t, Fd.t) Fieldslib.Field.t_with_perm -> 'c -> ('b -> Fd.t) * 'd) -> monitor: (([< `Read | `Set_and_create ], t, Async_unix.Import.Monitor.t) Fieldslib.Field.t_with_perm -> 'd -> ('b -> Async_unix.Import.Monitor.t) * 'e) -> inner_monitor: (([< `Read | `Set_and_create ], t, Async_unix.Import.Monitor.t) Fieldslib.Field.t_with_perm -> 'e -> ('b -> Async_unix.Import.Monitor.t) * 'f) -> background_writer_state: (([< `Read | `Set_and_create ], t, [ `Not_running | `Running | `Stopped_permanently ]) Fieldslib.Field.t_with_perm -> 'f -> ('b -> [ `Not_running | `Running | `Stopped_permanently ]) * 'g) -> background_writer_stopped: (([< `Read | `Set_and_create ], t, unit Async_unix.Import.Ivar.t) Fieldslib.Field.t_with_perm -> 'g -> ('b -> unit Async_unix.Import.Ivar.t) * 'h) -> syscall: (([< `Read | `Set_and_create ], t, [ `Per_cycle | `Periodic of Core.Time.Span.t ]) Fieldslib.Field.t_with_perm -> 'h -> ('b -> [ `Per_cycle | `Periodic of Core.Time.Span.t ]) * 'i) -> bytes_received: (([< `Read | `Set_and_create ], t, Core.Int63.t) Fieldslib.Field.t_with_perm -> 'i -> ('b -> Core.Int63.t) * 'j) -> bytes_written: (([< `Read | `Set_and_create ], t, Core.Int63.t) Fieldslib.Field.t_with_perm -> 'j -> ('b -> Core.Int63.t) * 'k) -> scheduled: (([< `Read | `Set_and_create ], t, Scheduled.t Core.sexp_opaque) Fieldslib.Field.t_with_perm -> 'k -> ('b -> Scheduled.t Core.sexp_opaque) * 'l) -> scheduled_bytes: (([< `Read | `Set_and_create ], t, int) Fieldslib.Field.t_with_perm -> 'l -> ('b -> int) * 'm) -> buf: (([< `Read | `Set_and_create ], t, Core.Bigstring.t Core.sexp_opaque) Fieldslib.Field.t_with_perm -> 'm -> ('b -> Core.Bigstring.t Core.sexp_opaque) * 'n) -> scheduled_back: (([< `Read | `Set_and_create ], t, int) Fieldslib.Field.t_with_perm -> 'n -> ('b -> int) * 'o) -> back: (([< `Read | `Set_and_create ], t, int) Fieldslib.Field.t_with_perm -> 'o -> ('b -> int) * 'p) -> flushes: (([< `Read | `Set_and_create ], t, (Core.Time_ns.t Async_unix.Import.Ivar.t * Core.Int63.t) Core.Queue.t Core.sexp_opaque) Fieldslib.Field.t_with_perm -> 'p -> ('b -> (Core.Time_ns.t Async_unix.Import.Ivar.t * Core.Int63.t) Core.Queue.t Core.sexp_opaque) * 'q) -> close_state: (([< `Read | `Set_and_create ], t, [ `Closed | `Closed_and_flushing | `Open ]) Fieldslib.Field.t_with_perm -> 'q -> ('b -> [ `Closed | `Closed_and_flushing | `Open ]) * 'r) -> close_finished: (([< `Read | `Set_and_create ], t, unit Async_unix.Import.Ivar.t) Fieldslib.Field.t_with_perm -> 'r -> ('b -> unit Async_unix.Import.Ivar.t) * 's) -> close_started: (([< `Read | `Set_and_create ], t, unit Async_unix.Import.Ivar.t) Fieldslib.Field.t_with_perm -> 's -> ('b -> unit Async_unix.Import.Ivar.t) * 't) -> producers_to_flush_at_close: (([< `Read | `Set_and_create ], t, (unit -> unit Async_unix.Import.Deferred.t) Core.Bag.t) Fieldslib.Field.t_with_perm -> 't -> ('b -> (unit -> unit Async_unix.Import.Deferred.t) Core.Bag.t) * 'u) -> flush_at_shutdown_elt: (([< `Read | `Set_and_create ], t, t Core.sexp_opaque Core.Bag.Elt.t option) Fieldslib.Field.t_with_perm -> 'u -> ('b -> t Core.sexp_opaque Core.Bag.Elt.t option) * 'v) -> check_buffer_age: (([< `Read | `Set_and_create ], t, t Core.sexp_opaque Check_buffer_age'.t Core.Bag.Elt.t option) Fieldslib.Field.t_with_perm -> 'v -> ('b -> t Core.sexp_opaque Check_buffer_age'.t Core.Bag.Elt.t option) * 'w) -> consumer_left: (([< `Read | `Set_and_create ], t, unit Async_unix.Import.Ivar.t) Fieldslib.Field.t_with_perm -> 'w -> ('b -> unit Async_unix.Import.Ivar.t) * 'x) -> raise_when_consumer_leaves: (([< `Read | `Set_and_create ], t, bool) Fieldslib.Field.t_with_perm -> 'x -> ('b -> bool) * 'y) -> open_flags: (([< `Read | `Set_and_create ], t, open_flags Async_unix.Import.Deferred.t) Fieldslib.Field.t_with_perm -> 'y -> ('b -> open_flags Async_unix.Import.Deferred.t) * 'z) -> line_ending: (([< `Read | `Set_and_create ], t, Line_ending.t) Fieldslib.Field.t_with_perm -> 'z -> ('b -> Line_ending.t) * 'a1) -> 'a -> ('b -> t) * 'a1
val create : id:Id.t -> fd:Fd.t -> monitor:Async_unix.Import.Monitor.t -> inner_monitor:Async_unix.Import.Monitor.t -> background_writer_state:[ `Not_running | `Running | `Stopped_permanently ] -> background_writer_stopped:unit Async_unix.Import.Ivar.t -> syscall:[ `Per_cycle | `Periodic of Core.Time.Span.t ] -> bytes_received:Core.Int63.t -> bytes_written:Core.Int63.t -> scheduled:Scheduled.t Core.sexp_opaque -> scheduled_bytes:int -> buf:Core.Bigstring.t Core.sexp_opaque -> scheduled_back:int -> back:int -> flushes: (Core.Time_ns.t Async_unix.Import.Ivar.t * Core.Int63.t) Core.Queue.t Core.sexp_opaque -> close_state:[ `Closed | `Closed_and_flushing | `Open ] -> close_finished:unit Async_unix.Import.Ivar.t -> close_started:unit Async_unix.Import.Ivar.t -> producers_to_flush_at_close: (unit -> unit Async_unix.Import.Deferred.t) Core.Bag.t -> flush_at_shutdown_elt:t Core.sexp_opaque Core.Bag.Elt.t option -> check_buffer_age:t Core.sexp_opaque Check_buffer_age'.t Core.Bag.Elt.t option -> consumer_left:unit Async_unix.Import.Ivar.t -> raise_when_consumer_leaves:bool -> open_flags:open_flags Async_unix.Import.Deferred.t -> line_ending:Line_ending.t -> t
val map : id: (([< `Read | `Set_and_create ], t, Id.t) Fieldslib.Field.t_with_perm -> Id.t) -> fd: (([< `Read | `Set_and_create ], t, Fd.t) Fieldslib.Field.t_with_perm -> Fd.t) -> monitor: (([< `Read | `Set_and_create ], t, Async_unix.Import.Monitor.t) Fieldslib.Field.t_with_perm -> Async_unix.Import.Monitor.t) -> inner_monitor: (([< `Read | `Set_and_create ], t, Async_unix.Import.Monitor.t) Fieldslib.Field.t_with_perm -> Async_unix.Import.Monitor.t) -> background_writer_state: (([< `Read | `Set_and_create ], t, [ `Not_running | `Running | `Stopped_permanently ]) Fieldslib.Field.t_with_perm -> [ `Not_running | `Running | `Stopped_permanently ]) -> background_writer_stopped: (([< `Read | `Set_and_create ], t, unit Async_unix.Import.Ivar.t) Fieldslib.Field.t_with_perm -> unit Async_unix.Import.Ivar.t) -> syscall: (([< `Read | `Set_and_create ], t, [ `Per_cycle | `Periodic of Core.Time.Span.t ]) Fieldslib.Field.t_with_perm -> [ `Per_cycle | `Periodic of Core.Time.Span.t ]) -> bytes_received: (([< `Read | `Set_and_create ], t, Core.Int63.t) Fieldslib.Field.t_with_perm -> Core.Int63.t) -> bytes_written: (([< `Read | `Set_and_create ], t, Core.Int63.t) Fieldslib.Field.t_with_perm -> Core.Int63.t) -> scheduled: (([< `Read | `Set_and_create ], t, Scheduled.t Core.sexp_opaque) Fieldslib.Field.t_with_perm -> Scheduled.t Core.sexp_opaque) -> scheduled_bytes: (([< `Read | `Set_and_create ], t, int) Fieldslib.Field.t_with_perm -> int) -> buf: (([< `Read | `Set_and_create ], t, Core.Bigstring.t Core.sexp_opaque) Fieldslib.Field.t_with_perm -> Core.Bigstring.t Core.sexp_opaque) -> scheduled_back: (([< `Read | `Set_and_create ], t, int) Fieldslib.Field.t_with_perm -> int) -> back: (([< `Read | `Set_and_create ], t, int) Fieldslib.Field.t_with_perm -> int) -> flushes: (([< `Read | `Set_and_create ], t, (Core.Time_ns.t Async_unix.Import.Ivar.t * Core.Int63.t) Core.Queue.t Core.sexp_opaque) Fieldslib.Field.t_with_perm -> (Core.Time_ns.t Async_unix.Import.Ivar.t * Core.Int63.t) Core.Queue.t Core.sexp_opaque) -> close_state: (([< `Read | `Set_and_create ], t, [ `Closed | `Closed_and_flushing | `Open ]) Fieldslib.Field.t_with_perm -> [ `Closed | `Closed_and_flushing | `Open ]) -> close_finished: (([< `Read | `Set_and_create ], t, unit Async_unix.Import.Ivar.t) Fieldslib.Field.t_with_perm -> unit Async_unix.Import.Ivar.t) -> close_started: (([< `Read | `Set_and_create ], t, unit Async_unix.Import.Ivar.t) Fieldslib.Field.t_with_perm -> unit Async_unix.Import.Ivar.t) -> producers_to_flush_at_close: (([< `Read | `Set_and_create ], t, (unit -> unit Async_unix.Import.Deferred.t) Core.Bag.t) Fieldslib.Field.t_with_perm -> (unit -> unit Async_unix.Import.Deferred.t) Core.Bag.t) -> flush_at_shutdown_elt: (([< `Read | `Set_and_create ], t, t Core.sexp_opaque Core.Bag.Elt.t option) Fieldslib.Field.t_with_perm -> t Core.sexp_opaque Core.Bag.Elt.t option) -> check_buffer_age: (([< `Read | `Set_and_create ], t, t Core.sexp_opaque Check_buffer_age'.t Core.Bag.Elt.t option) Fieldslib.Field.t_with_perm -> t Core.sexp_opaque Check_buffer_age'.t Core.Bag.Elt.t option) -> consumer_left: (([< `Read | `Set_and_create ], t, unit Async_unix.Import.Ivar.t) Fieldslib.Field.t_with_perm -> unit Async_unix.Import.Ivar.t) -> raise_when_consumer_leaves: (([< `Read | `Set_and_create ], t, bool) Fieldslib.Field.t_with_perm -> bool) -> open_flags: (([< `Read | `Set_and_create ], t, open_flags Async_unix.Import.Deferred.t) Fieldslib.Field.t_with_perm -> open_flags Async_unix.Import.Deferred.t) -> line_ending: (([< `Read | `Set_and_create ], t, Line_ending.t) Fieldslib.Field.t_with_perm -> Line_ending.t) -> t
val iter : id: (([< `Read | `Set_and_create ], t, Id.t) Fieldslib.Field.t_with_perm -> unit) -> fd: (([< `Read | `Set_and_create ], t, Fd.t) Fieldslib.Field.t_with_perm -> unit) -> monitor: (([< `Read | `Set_and_create ], t, Async_unix.Import.Monitor.t) Fieldslib.Field.t_with_perm -> unit) -> inner_monitor: (([< `Read | `Set_and_create ], t, Async_unix.Import.Monitor.t) Fieldslib.Field.t_with_perm -> unit) -> background_writer_state: (([< `Read | `Set_and_create ], t, [ `Not_running | `Running | `Stopped_permanently ]) Fieldslib.Field.t_with_perm -> unit) -> background_writer_stopped: (([< `Read | `Set_and_create ], t, unit Async_unix.Import.Ivar.t) Fieldslib.Field.t_with_perm -> unit) -> syscall: (([< `Read | `Set_and_create ], t, [ `Per_cycle | `Periodic of Core.Time.Span.t ]) Fieldslib.Field.t_with_perm -> unit) -> bytes_received: (([< `Read | `Set_and_create ], t, Core.Int63.t) Fieldslib.Field.t_with_perm -> unit) -> bytes_written: (([< `Read | `Set_and_create ], t, Core.Int63.t) Fieldslib.Field.t_with_perm -> unit) -> scheduled: (([< `Read | `Set_and_create ], t, Scheduled.t Core.sexp_opaque) Fieldslib.Field.t_with_perm -> unit) -> scheduled_bytes: (([< `Read | `Set_and_create ], t, int) Fieldslib.Field.t_with_perm -> unit) -> buf: (([< `Read | `Set_and_create ], t, Core.Bigstring.t Core.sexp_opaque) Fieldslib.Field.t_with_perm -> unit) -> scheduled_back: (([< `Read | `Set_and_create ], t, int) Fieldslib.Field.t_with_perm -> unit) -> back: (([< `Read | `Set_and_create ], t, int) Fieldslib.Field.t_with_perm -> unit) -> flushes: (([< `Read | `Set_and_create ], t, (Core.Time_ns.t Async_unix.Import.Ivar.t * Core.Int63.t) Core.Queue.t Core.sexp_opaque) Fieldslib.Field.t_with_perm -> unit) -> close_state: (([< `Read | `Set_and_create ], t, [ `Closed | `Closed_and_flushing | `Open ]) Fieldslib.Field.t_with_perm -> unit) -> close_finished: (([< `Read | `Set_and_create ], t, unit Async_unix.Import.Ivar.t) Fieldslib.Field.t_with_perm -> unit) -> close_started: (([< `Read | `Set_and_create ], t, unit Async_unix.Import.Ivar.t) Fieldslib.Field.t_with_perm -> unit) -> producers_to_flush_at_close: (([< `Read | `Set_and_create ], t, (unit -> unit Async_unix.Import.Deferred.t) Core.Bag.t) Fieldslib.Field.t_with_perm -> unit) -> flush_at_shutdown_elt: (([< `Read | `Set_and_create ], t, t Core.sexp_opaque Core.Bag.Elt.t option) Fieldslib.Field.t_with_perm -> unit) -> check_buffer_age: (([< `Read | `Set_and_create ], t, t Core.sexp_opaque Check_buffer_age'.t Core.Bag.Elt.t option) Fieldslib.Field.t_with_perm -> unit) -> consumer_left: (([< `Read | `Set_and_create ], t, unit Async_unix.Import.Ivar.t) Fieldslib.Field.t_with_perm -> unit) -> raise_when_consumer_leaves: (([< `Read | `Set_and_create ], t, bool) Fieldslib.Field.t_with_perm -> unit) -> open_flags: (([< `Read | `Set_and_create ], t, open_flags Async_unix.Import.Deferred.t) Fieldslib.Field.t_with_perm -> unit) -> line_ending: (([< `Read | `Set_and_create ], t, Line_ending.t) Fieldslib.Field.t_with_perm -> unit) -> unit
val fold : init:'a -> id: ('a -> ([< `Read | `Set_and_create ], t, Id.t) Fieldslib.Field.t_with_perm -> 'b) -> fd: ('b -> ([< `Read | `Set_and_create ], t, Fd.t) Fieldslib.Field.t_with_perm -> 'c) -> monitor: ('c -> ([< `Read | `Set_and_create ], t, Async_unix.Import.Monitor.t) Fieldslib.Field.t_with_perm -> 'd) -> inner_monitor: ('d -> ([< `Read | `Set_and_create ], t, Async_unix.Import.Monitor.t) Fieldslib.Field.t_with_perm -> 'e) -> background_writer_state: ('e -> ([< `Read | `Set_and_create ], t, [ `Not_running | `Running | `Stopped_permanently ]) Fieldslib.Field.t_with_perm -> 'f) -> background_writer_stopped: ('f -> ([< `Read | `Set_and_create ], t, unit Async_unix.Import.Ivar.t) Fieldslib.Field.t_with_perm -> 'g) -> syscall: ('g -> ([< `Read | `Set_and_create ], t, [ `Per_cycle | `Periodic of Core.Time.Span.t ]) Fieldslib.Field.t_with_perm -> 'h) -> bytes_received: ('h -> ([< `Read | `Set_and_create ], t, Core.Int63.t) Fieldslib.Field.t_with_perm -> 'i) -> bytes_written: ('i -> ([< `Read | `Set_and_create ], t, Core.Int63.t) Fieldslib.Field.t_with_perm -> 'j) -> scheduled: ('j -> ([< `Read | `Set_and_create ], t, Scheduled.t Core.sexp_opaque) Fieldslib.Field.t_with_perm -> 'k) -> scheduled_bytes: ('k -> ([< `Read | `Set_and_create ], t, int) Fieldslib.Field.t_with_perm -> 'l) -> buf: ('l -> ([< `Read | `Set_and_create ], t, Core.Bigstring.t Core.sexp_opaque) Fieldslib.Field.t_with_perm -> 'm) -> scheduled_back: ('m -> ([< `Read | `Set_and_create ], t, int) Fieldslib.Field.t_with_perm -> 'n) -> back: ('n -> ([< `Read | `Set_and_create ], t, int) Fieldslib.Field.t_with_perm -> 'o) -> flushes: ('o -> ([< `Read | `Set_and_create ], t, (Core.Time_ns.t Async_unix.Import.Ivar.t * Core.Int63.t) Core.Queue.t Core.sexp_opaque) Fieldslib.Field.t_with_perm -> 'p) -> close_state: ('p -> ([< `Read | `Set_and_create ], t, [ `Closed | `Closed_and_flushing | `Open ]) Fieldslib.Field.t_with_perm -> 'q) -> close_finished: ('q -> ([< `Read | `Set_and_create ], t, unit Async_unix.Import.Ivar.t) Fieldslib.Field.t_with_perm -> 'r) -> close_started: ('r -> ([< `Read | `Set_and_create ], t, unit Async_unix.Import.Ivar.t) Fieldslib.Field.t_with_perm -> 's) -> producers_to_flush_at_close: ('s -> ([< `Read | `Set_and_create ], t, (unit -> unit Async_unix.Import.Deferred.t) Core.Bag.t) Fieldslib.Field.t_with_perm -> 't) -> flush_at_shutdown_elt: ('t -> ([< `Read | `Set_and_create ], t, t Core.sexp_opaque Core.Bag.Elt.t option) Fieldslib.Field.t_with_perm -> 'u) -> check_buffer_age: ('u -> ([< `Read | `Set_and_create ], t, t Core.sexp_opaque Check_buffer_age'.t Core.Bag.Elt.t option) Fieldslib.Field.t_with_perm -> 'v) -> consumer_left: ('v -> ([< `Read | `Set_and_create ], t, unit Async_unix.Import.Ivar.t) Fieldslib.Field.t_with_perm -> 'w) -> raise_when_consumer_leaves: ('w -> ([< `Read | `Set_and_create ], t, bool) Fieldslib.Field.t_with_perm -> 'x) -> open_flags: ('x -> ([< `Read | `Set_and_create ], t, open_flags Async_unix.Import.Deferred.t) Fieldslib.Field.t_with_perm -> 'y) -> line_ending: ('y -> ([< `Read | `Set_and_create ], t, Line_ending.t) Fieldslib.Field.t_with_perm -> 'z) -> 'z
val map_poly : ([< `Read | `Set_and_create ], t, 'a) Fieldslib.Field.user -> 'a list
val for_all : id: (([< `Read | `Set_and_create ], t, Id.t) Fieldslib.Field.t_with_perm -> bool) -> fd: (([< `Read | `Set_and_create ], t, Fd.t) Fieldslib.Field.t_with_perm -> bool) -> monitor: (([< `Read | `Set_and_create ], t, Async_unix.Import.Monitor.t) Fieldslib.Field.t_with_perm -> bool) -> inner_monitor: (([< `Read | `Set_and_create ], t, Async_unix.Import.Monitor.t) Fieldslib.Field.t_with_perm -> bool) -> background_writer_state: (([< `Read | `Set_and_create ], t, [ `Not_running | `Running | `Stopped_permanently ]) Fieldslib.Field.t_with_perm -> bool) -> background_writer_stopped: (([< `Read | `Set_and_create ], t, unit Async_unix.Import.Ivar.t) Fieldslib.Field.t_with_perm -> bool) -> syscall: (([< `Read | `Set_and_create ], t, [ `Per_cycle | `Periodic of Core.Time.Span.t ]) Fieldslib.Field.t_with_perm -> bool) -> bytes_received: (([< `Read | `Set_and_create ], t, Core.Int63.t) Fieldslib.Field.t_with_perm -> bool) -> bytes_written: (([< `Read | `Set_and_create ], t, Core.Int63.t) Fieldslib.Field.t_with_perm -> bool) -> scheduled: (([< `Read | `Set_and_create ], t, Scheduled.t Core.sexp_opaque) Fieldslib.Field.t_with_perm -> bool) -> scheduled_bytes: (([< `Read | `Set_and_create ], t, int) Fieldslib.Field.t_with_perm -> bool) -> buf: (([< `Read | `Set_and_create ], t, Core.Bigstring.t Core.sexp_opaque) Fieldslib.Field.t_with_perm -> bool) -> scheduled_back: (([< `Read | `Set_and_create ], t, int) Fieldslib.Field.t_with_perm -> bool) -> back: (([< `Read | `Set_and_create ], t, int) Fieldslib.Field.t_with_perm -> bool) -> flushes: (([< `Read | `Set_and_create ], t, (Core.Time_ns.t Async_unix.Import.Ivar.t * Core.Int63.t) Core.Queue.t Core.sexp_opaque) Fieldslib.Field.t_with_perm -> bool) -> close_state: (([< `Read | `Set_and_create ], t, [ `Closed | `Closed_and_flushing | `Open ]) Fieldslib.Field.t_with_perm -> bool) -> close_finished: (([< `Read | `Set_and_create ], t, unit Async_unix.Import.Ivar.t) Fieldslib.Field.t_with_perm -> bool) -> close_started: (([< `Read | `Set_and_create ], t, unit Async_unix.Import.Ivar.t) Fieldslib.Field.t_with_perm -> bool) -> producers_to_flush_at_close: (([< `Read | `Set_and_create ], t, (unit -> unit Async_unix.Import.Deferred.t) Core.Bag.t) Fieldslib.Field.t_with_perm -> bool) -> flush_at_shutdown_elt: (([< `Read | `Set_and_create ], t, t Core.sexp_opaque Core.Bag.Elt.t option) Fieldslib.Field.t_with_perm -> bool) -> check_buffer_age: (([< `Read | `Set_and_create ], t, t Core.sexp_opaque Check_buffer_age'.t Core.Bag.Elt.t option) Fieldslib.Field.t_with_perm -> bool) -> consumer_left: (([< `Read | `Set_and_create ], t, unit Async_unix.Import.Ivar.t) Fieldslib.Field.t_with_perm -> bool) -> raise_when_consumer_leaves: (([< `Read | `Set_and_create ], t, bool) Fieldslib.Field.t_with_perm -> bool) -> open_flags: (([< `Read | `Set_and_create ], t, open_flags Async_unix.Import.Deferred.t) Fieldslib.Field.t_with_perm -> bool) -> line_ending: (([< `Read | `Set_and_create ], t, Line_ending.t) Fieldslib.Field.t_with_perm -> bool) -> bool
val exists : id: (([< `Read | `Set_and_create ], t, Id.t) Fieldslib.Field.t_with_perm -> bool) -> fd: (([< `Read | `Set_and_create ], t, Fd.t) Fieldslib.Field.t_with_perm -> bool) -> monitor: (([< `Read | `Set_and_create ], t, Async_unix.Import.Monitor.t) Fieldslib.Field.t_with_perm -> bool) -> inner_monitor: (([< `Read | `Set_and_create ], t, Async_unix.Import.Monitor.t) Fieldslib.Field.t_with_perm -> bool) -> background_writer_state: (([< `Read | `Set_and_create ], t, [ `Not_running | `Running | `Stopped_permanently ]) Fieldslib.Field.t_with_perm -> bool) -> background_writer_stopped: (([< `Read | `Set_and_create ], t, unit Async_unix.Import.Ivar.t) Fieldslib.Field.t_with_perm -> bool) -> syscall: (([< `Read | `Set_and_create ], t, [ `Per_cycle | `Periodic of Core.Time.Span.t ]) Fieldslib.Field.t_with_perm -> bool) -> bytes_received: (([< `Read | `Set_and_create ], t, Core.Int63.t) Fieldslib.Field.t_with_perm -> bool) -> bytes_written: (([< `Read | `Set_and_create ], t, Core.Int63.t) Fieldslib.Field.t_with_perm -> bool) -> scheduled: (([< `Read | `Set_and_create ], t, Scheduled.t Core.sexp_opaque) Fieldslib.Field.t_with_perm -> bool) -> scheduled_bytes: (([< `Read | `Set_and_create ], t, int) Fieldslib.Field.t_with_perm -> bool) -> buf: (([< `Read | `Set_and_create ], t, Core.Bigstring.t Core.sexp_opaque) Fieldslib.Field.t_with_perm -> bool) -> scheduled_back: (([< `Read | `Set_and_create ], t, int) Fieldslib.Field.t_with_perm -> bool) -> back: (([< `Read | `Set_and_create ], t, int) Fieldslib.Field.t_with_perm -> bool) -> flushes: (([< `Read | `Set_and_create ], t, (Core.Time_ns.t Async_unix.Import.Ivar.t * Core.Int63.t) Core.Queue.t Core.sexp_opaque) Fieldslib.Field.t_with_perm -> bool) -> close_state: (([< `Read | `Set_and_create ], t, [ `Closed | `Closed_and_flushing | `Open ]) Fieldslib.Field.t_with_perm -> bool) -> close_finished: (([< `Read | `Set_and_create ], t, unit Async_unix.Import.Ivar.t) Fieldslib.Field.t_with_perm -> bool) -> close_started: (([< `Read | `Set_and_create ], t, unit Async_unix.Import.Ivar.t) Fieldslib.Field.t_with_perm -> bool) -> producers_to_flush_at_close: (([< `Read | `Set_and_create ], t, (unit -> unit Async_unix.Import.Deferred.t) Core.Bag.t) Fieldslib.Field.t_with_perm -> bool) -> flush_at_shutdown_elt: (([< `Read | `Set_and_create ], t, t Core.sexp_opaque Core.Bag.Elt.t option) Fieldslib.Field.t_with_perm -> bool) -> check_buffer_age: (([< `Read | `Set_and_create ], t, t Core.sexp_opaque Check_buffer_age'.t Core.Bag.Elt.t option) Fieldslib.Field.t_with_perm -> bool) -> consumer_left: (([< `Read | `Set_and_create ], t, unit Async_unix.Import.Ivar.t) Fieldslib.Field.t_with_perm -> bool) -> raise_when_consumer_leaves: (([< `Read | `Set_and_create ], t, bool) Fieldslib.Field.t_with_perm -> bool) -> open_flags: (([< `Read | `Set_and_create ], t, open_flags Async_unix.Import.Deferred.t) Fieldslib.Field.t_with_perm -> bool) -> line_ending: (([< `Read | `Set_and_create ], t, Line_ending.t) Fieldslib.Field.t_with_perm -> bool) -> bool
val to_list : id: (([< `Read | `Set_and_create ], t, Id.t) Fieldslib.Field.t_with_perm -> 'a) -> fd: (([< `Read | `Set_and_create ], t, Fd.t) Fieldslib.Field.t_with_perm -> 'a) -> monitor: (([< `Read | `Set_and_create ], t, Async_unix.Import.Monitor.t) Fieldslib.Field.t_with_perm -> 'a) -> inner_monitor: (([< `Read | `Set_and_create ], t, Async_unix.Import.Monitor.t) Fieldslib.Field.t_with_perm -> 'a) -> background_writer_state: (([< `Read | `Set_and_create ], t, [ `Not_running | `Running | `Stopped_permanently ]) Fieldslib.Field.t_with_perm -> 'a) -> background_writer_stopped: (([< `Read | `Set_and_create ], t, unit Async_unix.Import.Ivar.t) Fieldslib.Field.t_with_perm -> 'a) -> syscall: (([< `Read | `Set_and_create ], t, [ `Per_cycle | `Periodic of Core.Time.Span.t ]) Fieldslib.Field.t_with_perm -> 'a) -> bytes_received: (([< `Read | `Set_and_create ], t, Core.Int63.t) Fieldslib.Field.t_with_perm -> 'a) -> bytes_written: (([< `Read | `Set_and_create ], t, Core.Int63.t) Fieldslib.Field.t_with_perm -> 'a) -> scheduled: (([< `Read | `Set_and_create ], t, Scheduled.t Core.sexp_opaque) Fieldslib.Field.t_with_perm -> 'a) -> scheduled_bytes: (([< `Read | `Set_and_create ], t, int) Fieldslib.Field.t_with_perm -> 'a) -> buf: (([< `Read | `Set_and_create ], t, Core.Bigstring.t Core.sexp_opaque) Fieldslib.Field.t_with_perm -> 'a) -> scheduled_back: (([< `Read | `Set_and_create ], t, int) Fieldslib.Field.t_with_perm -> 'a) -> back: (([< `Read | `Set_and_create ], t, int) Fieldslib.Field.t_with_perm -> 'a) -> flushes: (([< `Read | `Set_and_create ], t, (Core.Time_ns.t Async_unix.Import.Ivar.t * Core.Int63.t) Core.Queue.t Core.sexp_opaque) Fieldslib.Field.t_with_perm -> 'a) -> close_state: (([< `Read | `Set_and_create ], t, [ `Closed | `Closed_and_flushing | `Open ]) Fieldslib.Field.t_with_perm -> 'a) -> close_finished: (([< `Read | `Set_and_create ], t, unit Async_unix.Import.Ivar.t) Fieldslib.Field.t_with_perm -> 'a) -> close_started: (([< `Read | `Set_and_create ], t, unit Async_unix.Import.Ivar.t) Fieldslib.Field.t_with_perm -> 'a) -> producers_to_flush_at_close: (([< `Read | `Set_and_create ], t, (unit -> unit Async_unix.Import.Deferred.t) Core.Bag.t) Fieldslib.Field.t_with_perm -> 'a) -> flush_at_shutdown_elt: (([< `Read | `Set_and_create ], t, t Core.sexp_opaque Core.Bag.Elt.t option) Fieldslib.Field.t_with_perm -> 'a) -> check_buffer_age: (([< `Read | `Set_and_create ], t, t Core.sexp_opaque Check_buffer_age'.t Core.Bag.Elt.t option) Fieldslib.Field.t_with_perm -> 'a) -> consumer_left: (([< `Read | `Set_and_create ], t, unit Async_unix.Import.Ivar.t) Fieldslib.Field.t_with_perm -> 'a) -> raise_when_consumer_leaves: (([< `Read | `Set_and_create ], t, bool) Fieldslib.Field.t_with_perm -> 'a) -> open_flags: (([< `Read | `Set_and_create ], t, open_flags Async_unix.Import.Deferred.t) Fieldslib.Field.t_with_perm -> 'a) -> line_ending: (([< `Read | `Set_and_create ], t, Line_ending.t) Fieldslib.Field.t_with_perm -> 'a) -> 'a list
module Direct : sig ... end