                            (conj (:all-channels old-state) c)]
                        (merge old-state
                               {:publication new-p
+                               :pub-buffer sb
                                :all-channels new-channels})))))
         new-p))))
 

(defmethod stream->ch "hot-cold" [a-stream params]
  (log/info "Initialising hot-cold stream with params" (pr-str params))
  (let [date (extract-date params)
        ch (chan (buffer 1))
        _ (log/info "Getting stream-name and data")
        stream-name (get params :stream-name "__all__")
        _ (log/info "Finished getting stream-name and data")]

                     pub sub alts!]])
  (:import (java.net ServerSocket)
           (java.io DataOutput)))

;; TODO: Do something about the conflict between keywords and strings
;;       for the keys (e.g. stream-name)

