 
     :answer-aggregate
     (do
-        (map/add-data data)
-        (tmpl/output-map-stats (analyser/map-stats data (@app-state :neighborhoods)) (:key data)))
+      (map/add-data data)
+      (tmpl/output-map-stats (analyser/map-stats data (@app-state :neighborhoods)) (:key data)))
 
-    nil ; incomplete answers, to be aggregated
-    (async/put! incomplete-channel data)
-    
-))
+    :answers ; incomplete answers, to be aggregated
+      (async/put! incomplete-channel (:results data))))
 
 
 (defn receive-partial-data

                  (dissoc data aggregate-id)))
         (recur new-keys new-data))))))

(defn init
  []
  (let [data-channel (chan)
        user-channel (chan)
        incomplete-channel (chan)]

   (loop [received-keys #{}
          data {}]
     (let [val (<! channel)
           cdata              (js->clj val)
           category           (category cdata)
           aggregate-id       (keyword (category-to-map-id category))
