Module Direct

val iter : t -> id:(([< ], t, Id.t) Fieldslib.Field.t_with_perm -> t -> Id.t -> unit) -> fd:(([< ], t, Fd.t) Fieldslib.Field.t_with_perm -> t -> Fd.t -> unit) -> monitor:(([< ], t, Import.Monitor.t) Fieldslib.Field.t_with_perm -> t -> Import.Monitor.t -> unit) -> inner_monitor:(([< ], t, Import.Monitor.t) Fieldslib.Field.t_with_perm -> t -> Import.Monitor.t -> unit) -> background_writer_state:(([< ], t, [ ]) Fieldslib.Field.t_with_perm -> t -> [ ] -> unit) -> syscall:(([< ], t, [ ]) Fieldslib.Field.t_with_perm -> t -> [ ] -> unit) -> bytes_received:(([< ], t, Core.Std.Int63.t) Fieldslib.Field.t_with_perm -> t -> Core.Std.Int63.t -> unit) -> bytes_written:(([< ], t, Core.Std.Int63.t) Fieldslib.Field.t_with_perm -> t -> Core.Std.Int63.t -> unit) -> scheduled:(([< ], t, Scheduled.t Core.Std.sexp_opaque) Fieldslib.Field.t_with_perm -> t -> Scheduled.t Core.Std.sexp_opaque -> unit) -> scheduled_bytes:(([< ], t, int) Fieldslib.Field.t_with_perm -> t -> int -> unit) -> buf:(([< ], t, Core.Std.Bigstring.t Core.Std.sexp_opaque) Fieldslib.Field.t_with_perm -> t -> Core.Std.Bigstring.t Core.Std.sexp_opaque -> unit) -> scheduled_back:(([< ], t, int) Fieldslib.Field.t_with_perm -> t -> int -> unit) -> back:(([< ], t, int) Fieldslib.Field.t_with_perm -> t -> int -> unit) -> flushes:(([< ], t, (Core.Std.Time.t Import.Ivar.t * Core.Std.Int63.t) Core.Std.Queue.t Core.Std.sexp_opaque) Fieldslib.Field.t_with_perm -> t -> (Core.Std.Time.t Import.Ivar.t * Core.Std.Int63.t) Core.Std.Queue.t Core.Std.sexp_opaque -> unit) -> close_state:(([< ], t, [ ]) Fieldslib.Field.t_with_perm -> t -> [ ] -> unit) -> close_finished:(([< ], t, unit Import.Ivar.t) Fieldslib.Field.t_with_perm -> t -> unit Import.Ivar.t -> unit) -> close_started:(([< ], t, unit Import.Ivar.t) Fieldslib.Field.t_with_perm -> t -> unit Import.Ivar.t -> unit) -> producers_to_flush_at_close:(([< ], t, (unit -> unit Import.Deferred.t) Core.Std.Bag.t) Fieldslib.Field.t_with_perm -> t -> (unit -> unit Import.Deferred.t) Core.Std.Bag.t -> unit) -> flush_at_shutdown_elt:(([< ], t, t Core.Std.sexp_opaque Core.Std.Bag.Elt.t option) Fieldslib.Field.t_with_perm -> t -> t Core.Std.sexp_opaque Core.Std.Bag.Elt.t option -> unit) -> check_buffer_age:(([< ], t, t Core.Std.sexp_opaque Check_buffer_age'.t Core.Std.Bag.Elt.t option) Fieldslib.Field.t_with_perm -> t -> t Core.Std.sexp_opaque Check_buffer_age'.t Core.Std.Bag.Elt.t option -> unit) -> consumer_left:(([< ], t, unit Import.Ivar.t) Fieldslib.Field.t_with_perm -> t -> unit Import.Ivar.t -> unit) -> raise_when_consumer_leaves:(([< ], t, bool) Fieldslib.Field.t_with_perm -> t -> bool -> unit) -> open_flags:(([< ], t, open_flags Import.Deferred.t) Fieldslib.Field.t_with_perm -> t -> open_flags Import.Deferred.t -> 'a) -> 'a

val fold : t -> init:'a -> id:('a -> ([< ], t, Id.t) Fieldslib.Field.t_with_perm -> t -> Id.t -> 'b) -> fd:('b -> ([< ], t, Fd.t) Fieldslib.Field.t_with_perm -> t -> Fd.t -> 'c) -> monitor:('c -> ([< ], t, Import.Monitor.t) Fieldslib.Field.t_with_perm -> t -> Import.Monitor.t -> 'd) -> inner_monitor:('d -> ([< ], t, Import.Monitor.t) Fieldslib.Field.t_with_perm -> t -> Import.Monitor.t -> 'e) -> background_writer_state:('e -> ([< ], t, [ ]) Fieldslib.Field.t_with_perm -> t -> [ ] -> 'f) -> syscall:('f -> ([< ], t, [ ]) Fieldslib.Field.t_with_perm -> t -> [ ] -> 'g) -> bytes_received:('g -> ([< ], t, Core.Std.Int63.t) Fieldslib.Field.t_with_perm -> t -> Core.Std.Int63.t -> 'h) -> bytes_written:('h -> ([< ], t, Core.Std.Int63.t) Fieldslib.Field.t_with_perm -> t -> Core.Std.Int63.t -> 'i) -> scheduled:('i -> ([< ], t, Scheduled.t Core.Std.sexp_opaque) Fieldslib.Field.t_with_perm -> t -> Scheduled.t Core.Std.sexp_opaque -> 'j) -> scheduled_bytes:('j -> ([< ], t, int) Fieldslib.Field.t_with_perm -> t -> int -> 'k) -> buf:('k -> ([< ], t, Core.Std.Bigstring.t Core.Std.sexp_opaque) Fieldslib.Field.t_with_perm -> t -> Core.Std.Bigstring.t Core.Std.sexp_opaque -> 'l) -> scheduled_back:('l -> ([< ], t, int) Fieldslib.Field.t_with_perm -> t -> int -> 'm) -> back:('m -> ([< ], t, int) Fieldslib.Field.t_with_perm -> t -> int -> 'n) -> flushes:('n -> ([< ], t, (Core.Std.Time.t Import.Ivar.t * Core.Std.Int63.t) Core.Std.Queue.t Core.Std.sexp_opaque) Fieldslib.Field.t_with_perm -> t -> (Core.Std.Time.t Import.Ivar.t * Core.Std.Int63.t) Core.Std.Queue.t Core.Std.sexp_opaque -> 'o) -> close_state:('o -> ([< ], t, [ ]) Fieldslib.Field.t_with_perm -> t -> [ ] -> 'p) -> close_finished:('p -> ([< ], t, unit Import.Ivar.t) Fieldslib.Field.t_with_perm -> t -> unit Import.Ivar.t -> 'q) -> close_started:('q -> ([< ], t, unit Import.Ivar.t) Fieldslib.Field.t_with_perm -> t -> unit Import.Ivar.t -> 'r) -> producers_to_flush_at_close:('r -> ([< ], t, (unit -> unit Import.Deferred.t) Core.Std.Bag.t) Fieldslib.Field.t_with_perm -> t -> (unit -> unit Import.Deferred.t) Core.Std.Bag.t -> 's) -> flush_at_shutdown_elt:('s -> ([< ], t, t Core.Std.sexp_opaque Core.Std.Bag.Elt.t option) Fieldslib.Field.t_with_perm -> t -> t Core.Std.sexp_opaque Core.Std.Bag.Elt.t option -> 't) -> check_buffer_age:('t -> ([< ], t, t Core.Std.sexp_opaque Check_buffer_age'.t Core.Std.Bag.Elt.t option) Fieldslib.Field.t_with_perm -> t -> t Core.Std.sexp_opaque Check_buffer_age'.t Core.Std.Bag.Elt.t option -> 'u) -> consumer_left:('u -> ([< ], t, unit Import.Ivar.t) Fieldslib.Field.t_with_perm -> t -> unit Import.Ivar.t -> 'v) -> raise_when_consumer_leaves:('v -> ([< ], t, bool) Fieldslib.Field.t_with_perm -> t -> bool -> 'w) -> open_flags:('w -> ([< ], t, open_flags Import.Deferred.t) Fieldslib.Field.t_with_perm -> t -> open_flags Import.Deferred.t -> 'x) -> 'x

val set_all_mutable_fields : t -> fd:Fd.t -> background_writer_state:[ ] -> bytes_received:Core.Std.Int63.t -> bytes_written:Core.Std.Int63.t -> scheduled_bytes:int -> buf:Core.Std.Bigstring.t Core.Std.sexp_opaque -> scheduled_back:int -> back:int -> close_state:[ ] -> flush_at_shutdown_elt:t Core.Std.sexp_opaque Core.Std.Bag.Elt.t option -> check_buffer_age:t Core.Std.sexp_opaque Check_buffer_age'.t Core.Std.Bag.Elt.t option -> raise_when_consumer_leaves:bool -> unit