Module Async_unix__.Writer0.Fields

val names : string list
val backing_out_channel : ([< `Read | `Set_and_create ], tBacking_out_channel.t option) Fieldslib.Field.t_with_perm
val line_ending : ([< `Read | `Set_and_create ], tLine_ending.tFieldslib.Field.t_with_perm
val open_flags : ([< `Read | `Set_and_create ], topen_flags Async_unix__.Import.Deferred.tFieldslib.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.tFieldslib.Field.t_with_perm
val check_buffer_age : ([< `Read | `Set_and_create ], tt 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 ], tt 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.tFieldslib.Field.t_with_perm
val close_started : ([< `Read | `Set_and_create ], t, unit Async_unix__.Import.Ivar.tFieldslib.Field.t_with_perm
val close_finished : ([< `Read | `Set_and_create ], t, unit Async_unix__.Import.Ivar.tFieldslib.Field.t_with_perm
val close_state : ([< `Read | `Set_and_create ], t, [ `Closed | `Closed_and_flushing | `Open ]) Fieldslib.Field.t_with_perm
val flushes : ([< `Read | `Set_and_create ], t, (Core.Time_ns.t Async_unix__.Import.Ivar.t * Core.Int63.t) Core.Queue.t Core.sexp_opaqueFieldslib.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 ], tCore.Bigstring.t Core.sexp_opaqueFieldslib.Field.t_with_perm
val scheduled_bytes : ([< `Read | `Set_and_create ], t, int) Fieldslib.Field.t_with_perm
val scheduled : ([< `Read | `Set_and_create ], tScheduled.t Core.sexp_opaqueFieldslib.Field.t_with_perm
val bytes_written : ([< `Read | `Set_and_create ], tCore.Int63.tFieldslib.Field.t_with_perm
val bytes_received : ([< `Read | `Set_and_create ], tCore.Int63.tFieldslib.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.tFieldslib.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 ], tAsync_unix__.Import.Monitor.tFieldslib.Field.t_with_perm
val monitor : ([< `Read | `Set_and_create ], tAsync_unix__.Import.Monitor.tFieldslib.Field.t_with_perm
val fd : ([< `Read | `Set_and_create ], tAsync_unix.Fd.tFieldslib.Field.t_with_perm
val id : ([< `Read | `Set_and_create ], tId.tFieldslib.Field.t_with_perm
val make_creator : id:(([< `Read | `Set_and_create ], tId.tFieldslib.Field.t_with_perm ‑> 'a ‑> ('b ‑> Id.t) * 'c) ‑> fd:(([< `Read | `Set_and_create ], tAsync_unix.Fd.tFieldslib.Field.t_with_perm ‑> 'c ‑> ('b ‑> Async_unix.Fd.t) * 'd) ‑> monitor:(([< `Read | `Set_and_create ], tAsync_unix__.Import.Monitor.tFieldslib.Field.t_with_perm ‑> 'd ‑> ('b ‑> Async_unix__.Import.Monitor.t) * 'e) ‑> inner_monitor:(([< `Read | `Set_and_create ], tAsync_unix__.Import.Monitor.tFieldslib.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.tFieldslib.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 ], tCore.Int63.tFieldslib.Field.t_with_perm ‑> 'i ‑> ('b ‑> Core.Int63.t) * 'j) ‑> bytes_written:(([< `Read | `Set_and_create ], tCore.Int63.tFieldslib.Field.t_with_perm ‑> 'j ‑> ('b ‑> Core.Int63.t) * 'k) ‑> scheduled:(([< `Read | `Set_and_create ], tScheduled.t Core.sexp_opaqueFieldslib.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 ], tCore.Bigstring.t Core.sexp_opaqueFieldslib.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_opaqueFieldslib.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.tFieldslib.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.tFieldslib.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.tFieldslib.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 ], tt 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 ], tt 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.tFieldslib.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 ], topen_flags Async_unix__.Import.Deferred.tFieldslib.Field.t_with_perm ‑> 'y ‑> ('b ‑> open_flags Async_unix__.Import.Deferred.t) * 'z) ‑> line_ending:(([< `Read | `Set_and_create ], tLine_ending.tFieldslib.Field.t_with_perm ‑> 'z ‑> ('b ‑> Line_ending.t) * 'a1) ‑> backing_out_channel:(([< `Read | `Set_and_create ], tBacking_out_channel.t option) Fieldslib.Field.t_with_perm ‑> 'a1 ‑> ('b ‑> Backing_out_channel.t option) * 'b1) ‑> 'a ‑> ('b ‑> t) * 'b1
val create : id:Id.t ‑> fd:Async_unix.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 ‑> backing_out_channel:Backing_out_channel.t option ‑> t
val map : id:(([< `Read | `Set_and_create ], tId.tFieldslib.Field.t_with_perm ‑> Id.t) ‑> fd:(([< `Read | `Set_and_create ], tAsync_unix.Fd.tFieldslib.Field.t_with_perm ‑> Async_unix.Fd.t) ‑> monitor:(([< `Read | `Set_and_create ], tAsync_unix__.Import.Monitor.tFieldslib.Field.t_with_perm ‑> Async_unix__.Import.Monitor.t) ‑> inner_monitor:(([< `Read | `Set_and_create ], tAsync_unix__.Import.Monitor.tFieldslib.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.tFieldslib.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 ], tCore.Int63.tFieldslib.Field.t_with_perm ‑> Core.Int63.t) ‑> bytes_written:(([< `Read | `Set_and_create ], tCore.Int63.tFieldslib.Field.t_with_perm ‑> Core.Int63.t) ‑> scheduled:(([< `Read | `Set_and_create ], tScheduled.t Core.sexp_opaqueFieldslib.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 ], tCore.Bigstring.t Core.sexp_opaqueFieldslib.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_opaqueFieldslib.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.tFieldslib.Field.t_with_perm ‑> unit Async_unix__.Import.Ivar.t) ‑> close_started:(([< `Read | `Set_and_create ], t, unit Async_unix__.Import.Ivar.tFieldslib.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.tFieldslib.Field.t_with_perm ‑> (unit ‑> unit Async_unix__.Import.Deferred.t) Core.Bag.t) ‑> flush_at_shutdown_elt:(([< `Read | `Set_and_create ], tt 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 ], tt 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.tFieldslib.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 ], topen_flags Async_unix__.Import.Deferred.tFieldslib.Field.t_with_perm ‑> open_flags Async_unix__.Import.Deferred.t) ‑> line_ending:(([< `Read | `Set_and_create ], tLine_ending.tFieldslib.Field.t_with_perm ‑> Line_ending.t) ‑> backing_out_channel:(([< `Read | `Set_and_create ], tBacking_out_channel.t option) Fieldslib.Field.t_with_perm ‑> Backing_out_channel.t option) ‑> t
val iter : id:(([< `Read | `Set_and_create ], tId.tFieldslib.Field.t_with_perm ‑> unit) ‑> fd:(([< `Read | `Set_and_create ], tAsync_unix.Fd.tFieldslib.Field.t_with_perm ‑> unit) ‑> monitor:(([< `Read | `Set_and_create ], tAsync_unix__.Import.Monitor.tFieldslib.Field.t_with_perm ‑> unit) ‑> inner_monitor:(([< `Read | `Set_and_create ], tAsync_unix__.Import.Monitor.tFieldslib.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.tFieldslib.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 ], tCore.Int63.tFieldslib.Field.t_with_perm ‑> unit) ‑> bytes_written:(([< `Read | `Set_and_create ], tCore.Int63.tFieldslib.Field.t_with_perm ‑> unit) ‑> scheduled:(([< `Read | `Set_and_create ], tScheduled.t Core.sexp_opaqueFieldslib.Field.t_with_perm ‑> unit) ‑> scheduled_bytes:(([< `Read | `Set_and_create ], t, int) Fieldslib.Field.t_with_perm ‑> unit) ‑> buf:(([< `Read | `Set_and_create ], tCore.Bigstring.t Core.sexp_opaqueFieldslib.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_opaqueFieldslib.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.tFieldslib.Field.t_with_perm ‑> unit) ‑> close_started:(([< `Read | `Set_and_create ], t, unit Async_unix__.Import.Ivar.tFieldslib.Field.t_with_perm ‑> unit) ‑> producers_to_flush_at_close:(([< `Read | `Set_and_create ], t, (unit ‑> unit Async_unix__.Import.Deferred.t) Core.Bag.tFieldslib.Field.t_with_perm ‑> unit) ‑> flush_at_shutdown_elt:(([< `Read | `Set_and_create ], tt Core.sexp_opaque Core.Bag.Elt.t option) Fieldslib.Field.t_with_perm ‑> unit) ‑> check_buffer_age:(([< `Read | `Set_and_create ], tt 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.tFieldslib.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 ], topen_flags Async_unix__.Import.Deferred.tFieldslib.Field.t_with_perm ‑> unit) ‑> line_ending:(([< `Read | `Set_and_create ], tLine_ending.tFieldslib.Field.t_with_perm ‑> unit) ‑> backing_out_channel:(([< `Read | `Set_and_create ], tBacking_out_channel.t option) Fieldslib.Field.t_with_perm ‑> unit) ‑> unit
val fold : init:'a ‑> id:('a ‑> ([< `Read | `Set_and_create ], tId.tFieldslib.Field.t_with_perm ‑> 'b) ‑> fd:('b ‑> ([< `Read | `Set_and_create ], tAsync_unix.Fd.tFieldslib.Field.t_with_perm ‑> 'c) ‑> monitor:('c ‑> ([< `Read | `Set_and_create ], tAsync_unix__.Import.Monitor.tFieldslib.Field.t_with_perm ‑> 'd) ‑> inner_monitor:('d ‑> ([< `Read | `Set_and_create ], tAsync_unix__.Import.Monitor.tFieldslib.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.tFieldslib.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 ], tCore.Int63.tFieldslib.Field.t_with_perm ‑> 'i) ‑> bytes_written:('i ‑> ([< `Read | `Set_and_create ], tCore.Int63.tFieldslib.Field.t_with_perm ‑> 'j) ‑> scheduled:('j ‑> ([< `Read | `Set_and_create ], tScheduled.t Core.sexp_opaqueFieldslib.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 ], tCore.Bigstring.t Core.sexp_opaqueFieldslib.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_opaqueFieldslib.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.tFieldslib.Field.t_with_perm ‑> 'r) ‑> close_started:('r ‑> ([< `Read | `Set_and_create ], t, unit Async_unix__.Import.Ivar.tFieldslib.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.tFieldslib.Field.t_with_perm ‑> 't) ‑> flush_at_shutdown_elt:('t ‑> ([< `Read | `Set_and_create ], tt Core.sexp_opaque Core.Bag.Elt.t option) Fieldslib.Field.t_with_perm ‑> 'u) ‑> check_buffer_age:('u ‑> ([< `Read | `Set_and_create ], tt 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.tFieldslib.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 ], topen_flags Async_unix__.Import.Deferred.tFieldslib.Field.t_with_perm ‑> 'y) ‑> line_ending:('y ‑> ([< `Read | `Set_and_create ], tLine_ending.tFieldslib.Field.t_with_perm ‑> 'z) ‑> backing_out_channel:('z ‑> ([< `Read | `Set_and_create ], tBacking_out_channel.t option) Fieldslib.Field.t_with_perm ‑> 'a1) ‑> 'a1
val map_poly : ([< `Read | `Set_and_create ], t'aFieldslib.Field.user ‑> 'a list
val for_all : id:(([< `Read | `Set_and_create ], tId.tFieldslib.Field.t_with_perm ‑> bool) ‑> fd:(([< `Read | `Set_and_create ], tAsync_unix.Fd.tFieldslib.Field.t_with_perm ‑> bool) ‑> monitor:(([< `Read | `Set_and_create ], tAsync_unix__.Import.Monitor.tFieldslib.Field.t_with_perm ‑> bool) ‑> inner_monitor:(([< `Read | `Set_and_create ], tAsync_unix__.Import.Monitor.tFieldslib.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.tFieldslib.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 ], tCore.Int63.tFieldslib.Field.t_with_perm ‑> bool) ‑> bytes_written:(([< `Read | `Set_and_create ], tCore.Int63.tFieldslib.Field.t_with_perm ‑> bool) ‑> scheduled:(([< `Read | `Set_and_create ], tScheduled.t Core.sexp_opaqueFieldslib.Field.t_with_perm ‑> bool) ‑> scheduled_bytes:(([< `Read | `Set_and_create ], t, int) Fieldslib.Field.t_with_perm ‑> bool) ‑> buf:(([< `Read | `Set_and_create ], tCore.Bigstring.t Core.sexp_opaqueFieldslib.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_opaqueFieldslib.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.tFieldslib.Field.t_with_perm ‑> bool) ‑> close_started:(([< `Read | `Set_and_create ], t, unit Async_unix__.Import.Ivar.tFieldslib.Field.t_with_perm ‑> bool) ‑> producers_to_flush_at_close:(([< `Read | `Set_and_create ], t, (unit ‑> unit Async_unix__.Import.Deferred.t) Core.Bag.tFieldslib.Field.t_with_perm ‑> bool) ‑> flush_at_shutdown_elt:(([< `Read | `Set_and_create ], tt Core.sexp_opaque Core.Bag.Elt.t option) Fieldslib.Field.t_with_perm ‑> bool) ‑> check_buffer_age:(([< `Read | `Set_and_create ], tt 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.tFieldslib.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 ], topen_flags Async_unix__.Import.Deferred.tFieldslib.Field.t_with_perm ‑> bool) ‑> line_ending:(([< `Read | `Set_and_create ], tLine_ending.tFieldslib.Field.t_with_perm ‑> bool) ‑> backing_out_channel:(([< `Read | `Set_and_create ], tBacking_out_channel.t option) Fieldslib.Field.t_with_perm ‑> bool) ‑> bool
val exists : id:(([< `Read | `Set_and_create ], tId.tFieldslib.Field.t_with_perm ‑> bool) ‑> fd:(([< `Read | `Set_and_create ], tAsync_unix.Fd.tFieldslib.Field.t_with_perm ‑> bool) ‑> monitor:(([< `Read | `Set_and_create ], tAsync_unix__.Import.Monitor.tFieldslib.Field.t_with_perm ‑> bool) ‑> inner_monitor:(([< `Read | `Set_and_create ], tAsync_unix__.Import.Monitor.tFieldslib.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.tFieldslib.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 ], tCore.Int63.tFieldslib.Field.t_with_perm ‑> bool) ‑> bytes_written:(([< `Read | `Set_and_create ], tCore.Int63.tFieldslib.Field.t_with_perm ‑> bool) ‑> scheduled:(([< `Read | `Set_and_create ], tScheduled.t Core.sexp_opaqueFieldslib.Field.t_with_perm ‑> bool) ‑> scheduled_bytes:(([< `Read | `Set_and_create ], t, int) Fieldslib.Field.t_with_perm ‑> bool) ‑> buf:(([< `Read | `Set_and_create ], tCore.Bigstring.t Core.sexp_opaqueFieldslib.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_opaqueFieldslib.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.tFieldslib.Field.t_with_perm ‑> bool) ‑> close_started:(([< `Read | `Set_and_create ], t, unit Async_unix__.Import.Ivar.tFieldslib.Field.t_with_perm ‑> bool) ‑> producers_to_flush_at_close:(([< `Read | `Set_and_create ], t, (unit ‑> unit Async_unix__.Import.Deferred.t) Core.Bag.tFieldslib.Field.t_with_perm ‑> bool) ‑> flush_at_shutdown_elt:(([< `Read | `Set_and_create ], tt Core.sexp_opaque Core.Bag.Elt.t option) Fieldslib.Field.t_with_perm ‑> bool) ‑> check_buffer_age:(([< `Read | `Set_and_create ], tt 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.tFieldslib.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 ], topen_flags Async_unix__.Import.Deferred.tFieldslib.Field.t_with_perm ‑> bool) ‑> line_ending:(([< `Read | `Set_and_create ], tLine_ending.tFieldslib.Field.t_with_perm ‑> bool) ‑> backing_out_channel:(([< `Read | `Set_and_create ], tBacking_out_channel.t option) Fieldslib.Field.t_with_perm ‑> bool) ‑> bool
val to_list : id:(([< `Read | `Set_and_create ], tId.tFieldslib.Field.t_with_perm ‑> 'a) ‑> fd:(([< `Read | `Set_and_create ], tAsync_unix.Fd.tFieldslib.Field.t_with_perm ‑> 'a) ‑> monitor:(([< `Read | `Set_and_create ], tAsync_unix__.Import.Monitor.tFieldslib.Field.t_with_perm ‑> 'a) ‑> inner_monitor:(([< `Read | `Set_and_create ], tAsync_unix__.Import.Monitor.tFieldslib.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.tFieldslib.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 ], tCore.Int63.tFieldslib.Field.t_with_perm ‑> 'a) ‑> bytes_written:(([< `Read | `Set_and_create ], tCore.Int63.tFieldslib.Field.t_with_perm ‑> 'a) ‑> scheduled:(([< `Read | `Set_and_create ], tScheduled.t Core.sexp_opaqueFieldslib.Field.t_with_perm ‑> 'a) ‑> scheduled_bytes:(([< `Read | `Set_and_create ], t, int) Fieldslib.Field.t_with_perm ‑> 'a) ‑> buf:(([< `Read | `Set_and_create ], tCore.Bigstring.t Core.sexp_opaqueFieldslib.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_opaqueFieldslib.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.tFieldslib.Field.t_with_perm ‑> 'a) ‑> close_started:(([< `Read | `Set_and_create ], t, unit Async_unix__.Import.Ivar.tFieldslib.Field.t_with_perm ‑> 'a) ‑> producers_to_flush_at_close:(([< `Read | `Set_and_create ], t, (unit ‑> unit Async_unix__.Import.Deferred.t) Core.Bag.tFieldslib.Field.t_with_perm ‑> 'a) ‑> flush_at_shutdown_elt:(([< `Read | `Set_and_create ], tt Core.sexp_opaque Core.Bag.Elt.t option) Fieldslib.Field.t_with_perm ‑> 'a) ‑> check_buffer_age:(([< `Read | `Set_and_create ], tt 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.tFieldslib.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 ], topen_flags Async_unix__.Import.Deferred.tFieldslib.Field.t_with_perm ‑> 'a) ‑> line_ending:(([< `Read | `Set_and_create ], tLine_ending.tFieldslib.Field.t_with_perm ‑> 'a) ‑> backing_out_channel:(([< `Read | `Set_and_create ], tBacking_out_channel.t option) Fieldslib.Field.t_with_perm ‑> 'a) ‑> 'a list
module Direct : sig ... end