 
   (initialize server-state "opt/server-config-1.edn")
 
-  (tweet-processor server-state)
-
-  (let [[in out] (-> @server-state :app :g-chans)]
-    (go
-      (>! in {:topic :stop-stream})
-      (println (<! out))))
-
+  (def stop-stream
+    (let [{:keys [follow track handler credentials]} (:app @server-state)]
+      (start-filter-stream follow track handler credentials)))
+  (stop-stream)
 
   (def stop-server
     (do

  (info @server-state)
  (when (:http-server? @server-state)
    (run-server (site #'all-routes) {:port (:port @server-state) :join? false}))
  (tweet-processor server-state)
  (when (:backup? @server-state)
    (start-executor (:backup-folder @server-state))))


            [ceres.collector :refer [store set-db] :as collector]
            [ceres.curator :refer [get-articles-count get-news-diffusion get-news-frequencies] :as curator]
            [ceres.executor :refer [start-executor]]
            [gezwitscher.core :refer [start-filter-stream]]
            [clojure.java.io :as io]
            [clojure.core.async :refer [close! put! timeout sub chan <!! >!! <! >! go go-loop] :as async]
            [taoensso.timbre :as timbre]))
