                      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)
 

(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")]

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

