package async_unix

  1. Overview
  2. Docs
Legend:
Library
Module
Module type
Parameter
Class
Class type
type 'a t = {
  1. writer : 'a;
  2. maximum_age : Core.Time_ns.Span.t;
  3. mutable bytes_received_at_now_minus_maximum_age : Core.Int63.t;
  4. bytes_received_queue : Core.Int63.t Core.Queue.t;
  5. times_received_queue : Core.Time_ns.t Core.Queue.t;
  6. mutable bytes_seen : Core.Int63.t;
  7. mutable too_old : unit Async_unix.Import.Ivar.t;
}
val too_old : 'a t -> unit Async_unix.Import.Ivar.t
val set_too_old : 'a t -> unit Async_unix.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
val sexp_of_t : 'a. ('a -> Sexplib.Sexp.t) -> 'a t -> Sexplib.Sexp.t