client.clj

;; client
(defonce client-list (atom nil))

(defn handle-update [{:keys [type val]}]
  (if (= type :snapshot)
    (reset! client-list val)
    (when @client-list
      (when (< 9 (count @client-list))
        (swap! client-list butlast))
      (swap! client-list conj val))))

(defn client-start []
  (subscribe handle-update)
  (get-snapshot))

(defn client-stop []
  (subscribe identity))