 
 (defspout reaction-spout ["conv-id" "reaction"] {:prepare true}
   [conf context collector]
-(defn data-updater [update-fn init-fn]
-  (fn [data conv-id inputs]
-    (let [value (or (get data conv-id) (init-fn))]
-      (update-fn value inputs))))
-
   (let [n-convs 3
         start-n 3
         reaction-gen (atom (make-reaction-gen n-convs start-n))]

        (println "RUNNING BOLT")
        (swap! data update-data conv-id reaction)
        (emit-bolt! collector
                    [conv-id (:matrix (get @data conv-id))]
                    :anchor tuple))))))


(defn mk-topology []

    {"1" (spout-spec reaction-spout)}
    ; Bolts:
    {"2" (bolt-spec {"1"  ["conv-id"]}
                    rating-matrix)
     "3" (bolt-spec {"2" ["conv-id"]}
                    ptpt-pca)
     }))


