package mirage-flow

  1. Overview
  2. Docs
type t = {
  1. _read_bytes : int64 Pervasives.ref;
  2. _read_ops : int64 Pervasives.ref;
  3. _write_bytes : int64 Pervasives.ref;
  4. _write_ops : int64 Pervasives.ref;
  5. _finish : float option Pervasives.ref;
  6. start : float;
  7. time : unit -> float;
  8. t : [ `Ok of unit | `Error of [ `Msg of string ] ] Lwt.t;
}
val stats : t -> Mirage_flow_stats.t
val start : (module V1.CLOCK) -> (module V1_LWT.FLOW with type flow = 'a) -> 'a -> (module V1_LWT.FLOW with type flow = 'b) -> 'b -> unit -> t
val wait : t -> [ `Error of [ `Msg of string ] | `Ok of unit ] Lwt.t
val copy : (module V1.CLOCK) -> (module V1_LWT.FLOW with type flow = 'a) -> 'a -> (module V1_LWT.FLOW with type flow = 'b) -> 'b -> unit -> [> `Error of [> `Msg of string ] | `Ok of Mirage_flow_stats.t ] Lwt.t