Module Fields

val names : string list

val open_flags : ([< ], t, open_flags Import.Deferred.t) Fieldslib.Field.t_with_perm

val raise_when_consumer_leaves : ([< ], t, bool) Fieldslib.Field.t_with_perm

val consumer_left : ([< ], t, unit Import.Ivar.t) Fieldslib.Field.t_with_perm

val check_buffer_age : ([< ], t, t Core.Std.sexp_opaque Check_buffer_age'.t Core.Std.Bag.Elt.t option) Fieldslib.Field.t_with_perm

val flush_at_shutdown_elt : ([< ], t, t Core.Std.sexp_opaque Core.Std.Bag.Elt.t option) Fieldslib.Field.t_with_perm

val producers_to_flush_at_close : ([< ], t, (unit -> unit Import.Deferred.t) Core.Std.Bag.t) Fieldslib.Field.t_with_perm

val close_started : ([< ], t, unit Import.Ivar.t) Fieldslib.Field.t_with_perm

val close_finished : ([< ], t, unit Import.Ivar.t) Fieldslib.Field.t_with_perm

val close_state : ([< ], t, [ ]) Fieldslib.Field.t_with_perm

val 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

val back : ([< ], t, int) Fieldslib.Field.t_with_perm

val scheduled_back : ([< ], t, int) Fieldslib.Field.t_with_perm

val buf : ([< ], t, Core.Std.Bigstring.t Core.Std.sexp_opaque) Fieldslib.Field.t_with_perm

val scheduled_bytes : ([< ], t, int) Fieldslib.Field.t_with_perm

val scheduled : ([< ], t, Scheduled.t Core.Std.sexp_opaque) Fieldslib.Field.t_with_perm

val bytes_written : ([< ], t, Core.Std.Int63.t) Fieldslib.Field.t_with_perm

val bytes_received : ([< ], t, Core.Std.Int63.t) Fieldslib.Field.t_with_perm

val syscall : ([< ], t, [ ]) Fieldslib.Field.t_with_perm

val background_writer_state : ([< ], t, [ ]) Fieldslib.Field.t_with_perm

val inner_monitor : ([< ], t, Import.Monitor.t) Fieldslib.Field.t_with_perm

val monitor : ([< ], t, Import.Monitor.t) Fieldslib.Field.t_with_perm

val fd : ([< ], t, Fd.t) Fieldslib.Field.t_with_perm

val id : ([< ], t, Id.t) Fieldslib.Field.t_with_perm

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

val create : id:Id.t -> fd:Fd.t -> monitor:Import.Monitor.t -> inner_monitor:Import.Monitor.t -> background_writer_state:[ ] -> syscall:[ ] -> bytes_received:Core.Std.Int63.t -> bytes_written:Core.Std.Int63.t -> scheduled:Scheduled.t Core.Std.sexp_opaque -> scheduled_bytes:int -> buf:Core.Std.Bigstring.t Core.Std.sexp_opaque -> scheduled_back:int -> back:int -> flushes:(Core.Std.Time.t Import.Ivar.t * Core.Std.Int63.t) Core.Std.Queue.t Core.Std.sexp_opaque -> close_state:[ ] -> close_finished:unit Import.Ivar.t -> close_started:unit Import.Ivar.t -> producers_to_flush_at_close:(unit -> unit Import.Deferred.t) Core.Std.Bag.t -> 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 -> consumer_left:unit Import.Ivar.t -> raise_when_consumer_leaves:bool -> open_flags:open_flags Import.Deferred.t -> t

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

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

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

val map_poly : ([< ], t, 'a) Fieldslib.Field.user -> 'a list

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

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

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