package async_unix

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