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