Module Async_unix.Writer0.Check_buffer_age'

type 'a t = {

writer : 'a;

maximum_age : Core.Time_ns.Span.t;

mutable bytes_received_at_now_minus_maximum_age : Core.Int63.t;

bytes_received_queue : Core.Int63.t Core.Queue.t;

times_received_queue : Core.Time_ns.t Core.Queue.t;

mutable bytes_seen : Core.Int63.t;

mutable too_old : unit Import.Ivar.t;

}

val sexp_of_t : a. ('a ‑> Sexplib.Sexp.t) ‑> 'a t ‑> Sexplib.Sexp.t

val too_old : 'a t ‑> unit Import.Ivar.t

val set_too_old : 'a t ‑> unit Import.Ivar.t ‑> unit

val bytes_seen : 'a t ‑> Core.Int63.t

val set_bytes_seen : 'a t ‑> Core.Int63.t ‑> unit

val times_received_queue : 'a t ‑> Core.Time_ns.t Core.Queue.t

val bytes_received_queue : 'a t ‑> Core.Int63.t Core.Queue.t

val bytes_received_at_now_minus_maximum_age : 'a t ‑> Core.Int63.t

val set_bytes_received_at_now_minus_maximum_age : 'a t ‑> Core.Int63.t ‑> unit

val maximum_age : 'a t ‑> Core.Time_ns.Span.t

val writer : 'a t ‑> 'a

module Fields : sig ... end