 
 (go-loop []
          (let [chunk (<! c/prev-chunks-chan)]
-           (doseq [t chunk]
-             (put! c/prev-tweets-chan t))
+           (doseq [t chunk] (put! c/prev-tweets-chan t))
            (<! (timeout 50))
            (recur)))

      (util/swap-pmap app :by-rt-since-startup rt-id (inc (get (:by-rt-since-startup state) rt-id 0)))
      (util/swap-pmap app :by-reach rt-id (+ (get (:by-reach state) rt-id 0) (:followers_count (:user tweet))))
      (when (> rt-count (:retweet_count (rt-id (:tweets-map state)))) (add-to-tweets-map! app :tweets-map rt)))))

(defn ignore-tweet!
  "only increment counter, otherwise ignore tweet"
  [tweet app]
  (let [state @app]
    (swap! app assoc :count (inc (:count state)))))

(defn add-tweet!
  "increment counter, add tweet to tweets map and to sorted sets by id and by followers"


(go-loop [] (let [t (<! c/prev-tweets-chan)]
              (add-tweet! t state/app)
              (recur)))

(go-loop []
