Module MorePipes (.ml)

module MorePipes: sig .. end

val interleave : 'a Async.Std.Pipe.Reader.t list -> 'a Async.Std.Pipe.Reader.t

val pipe_interleave : unit -> unit Async.Std.Deferred.t

val broadcast : 'a Async.Std.Pipe.Reader.t ->
       'a Async.Std.Pipe.Writer.t list -> unit Async.Std.Deferred.t

val pipe_broadcast : unit -> unit Async.Std.Deferred.t

module PubSub: sig .. end

val pipe_pub_sub : unit -> unit Async.Std.Deferred.t

val main : unit -> unit Async.Std.Deferred.t