open Core open Async type t = { events : Event.t Pipe.Reader.t list ; close_result : unit Or_error.t Deferred.t }