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