Module Async_unix__.Writer0.Fields.Direct
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, Async_unix.Fd.t) Fieldslib.Field.t_with_perm ‑> t ‑> Async_unix.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) ‑> backing_out_channel:(([< `Read | `Set_and_create ], t, Backing_out_channel.t option) Fieldslib.Field.t_with_perm ‑> t ‑> Backing_out_channel.t option ‑> 'z) ‑> 'zval 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, Async_unix.Fd.t) Fieldslib.Field.t_with_perm ‑> t ‑> Async_unix.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) ‑> backing_out_channel:('z ‑> ([< `Read | `Set_and_create ], t, Backing_out_channel.t option) Fieldslib.Field.t_with_perm ‑> t ‑> Backing_out_channel.t option ‑> 'a1) ‑> 'a1val 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, Async_unix.Fd.t) Fieldslib.Field.t_with_perm ‑> t ‑> Async_unix.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) ‑> backing_out_channel:(([< `Read | `Set_and_create ], t, Backing_out_channel.t option) Fieldslib.Field.t_with_perm ‑> t ‑> Backing_out_channel.t option ‑> bool) ‑> boolval 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, Async_unix.Fd.t) Fieldslib.Field.t_with_perm ‑> t ‑> Async_unix.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) ‑> backing_out_channel:(([< `Read | `Set_and_create ], t, Backing_out_channel.t option) Fieldslib.Field.t_with_perm ‑> t ‑> Backing_out_channel.t option ‑> bool) ‑> boolval 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, Async_unix.Fd.t) Fieldslib.Field.t_with_perm ‑> t ‑> Async_unix.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) ‑> backing_out_channel:(([< `Read | `Set_and_create ], t, Backing_out_channel.t option) Fieldslib.Field.t_with_perm ‑> t ‑> Backing_out_channel.t option ‑> 'a) ‑> 'a listval 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, Async_unix.Fd.t) Fieldslib.Field.t_with_perm ‑> t ‑> Async_unix.Fd.t ‑> Async_unix.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) ‑> backing_out_channel:(([< `Read | `Set_and_create ], t, Backing_out_channel.t option) Fieldslib.Field.t_with_perm ‑> t ‑> Backing_out_channel.t option ‑> Backing_out_channel.t option) ‑> t