                               [this :real-streams]
                               (conj real-streams stream-name)))))))))
   (create-virtual-stream-endpoint! [this stream-name]
-    (let [ch (chan (sliding-buffer 1))
+    (let [ch (chan)
           ch-mult (mult ch)]
       (dosync (alter state assoc-in [:virtual-streams stream-name]
                      {:channel ch :mult-channel ch-mult}))

  (let [c (chan 1)
        mult-global (mult c)
        global-channel {:channel c :mult-channel mult-global}
        telnet-projections-channel (chan (sliding-buffer 1))
        telnet-events-channel (chan (sliding-buffer 1))
        telnet-mix (mix telnet-projections-channel)
        projection-channel (chan)
        projection-mix (mix projection-channel)

                text "streaming...")
      (go
        (loop [elem (<! ch)]
          (when (not (empty? @sockets))
            (let [edn (prn-str elem)
                  bs (bytes (byte-array (map (comp byte int) edn)))]
              (dorun (pmap #(let [os (.getOutputStream %)]
