Broadcast_pipe.Writer
type 'a t
The write side of the broadcast pipe
val write : 'a t -> 'a -> unit Async_kernel.Deferred.t
Write an item to the pipe. The returned Deferred with be determined when all downstream consumers have finished processing.
val close : 'a t -> unit
Stop listening to the underlying pipe. This cascades to all listeners