this repo has no description
1open Types 2 3type item = { 4 msg : protocol_msg; 5 transmits : int Kcas.Loc.t; 6 created : Mtime.span; 7} 8 9type t 10 11val create : unit -> t 12val enqueue : t -> protocol_msg -> transmits:int -> created:Mtime.span -> unit 13val depth : t -> int 14 15val drain : 16 t -> max_bytes:int -> encode_size:(protocol_msg -> int) -> protocol_msg list 17 18val invalidate : 19 t -> 20 invalidates:(newer:protocol_msg -> older:protocol_msg -> bool) -> 21 protocol_msg -> 22 unit