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

      (timbre/set-config! [:shared-appender-config :spit-filename] (:logfile @server-state))
      (run-server (site #'all-routes) {:port (:port @server-state) :join? false})))

  )

  "Dispatch incoming websocket-requests"
  [{:keys [topic data] :as package}]
  (case topic
    :tweets-count (assoc package :data (curator/get-tweet-count))
    :init (assoc package :data
                 {:recent-articles (-> @server-state :app :recent-articles)
