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