Pipe_lib.Broadcast_pipe
A broadcast_pipe allows multiple readers for a single writer without needing to fork explicitly. It is always synchronous and always has at least one value in it.
exception Already_closed of string
module Reader : sig ... end
module Writer : sig ... end
val create : 'a -> 'a Reader.t * 'a Writer.t
Create a shared pipe and seed it with 'a
val map : 'a Reader.t -> f:( 'a -> 'b ) -> 'b Reader.t