Module MorePipes.PubSub (.ml)

module PubSub: sig .. end

type 'a t = 'a Async.Std.Pipe.Writer.t list Pervasives.ref 
val create : unit -> 'a t
val pub : 'a t -> 'a -> unit Async.Std.Deferred.t
val sub : 'a t -> 'a Async.Std.Pipe.Reader.t
val close : 'a t -> unit