type t
module Event : sig ... end
val envelope_received : t ‑> Types.Envelope.t ‑> unit
val create : unit ‑> t
val event_stream : t ‑> Event.t Async.Pipe.Reader.t