A TCP server for warp. Funnels all client messages in a single input stream. Clients are subscribed to an event bus which is used to broadcast messages.
A TCP server for warp. Funnels all client messages in a single input stream. Clients are subscribed to an event bus which is used to broadcast messages.
(broadcast {:keys [bus]} msg)
(decode x)
(encode x)
(make-handler bus mux)
(make-mux)
(make-pipeline initial-pipeline)
(make-transport options)
cljdoc is a website building & hosting documentation for Clojure/Script libraries
× close