     ;; Read from the dechunker chan in a go loop and drop into turbine.
     (go-loop []
       (let [tweet-chunk (<! transfer-chan)]
-        ; (println tweet-chunk)
         (turbine-in tweet-chunk))
       (recur))
     
-    (statuses-filter :params {:track "trump"}
+    (statuses-filter :params {:track ["trump" "pence"]}
                      :oauth-creds creds
                      :callbacks *callback*)))

    (catch Exception e 
    (do
      (println e)
      (println text)
      {:text ""}))))

(defn parse-filter []
  (comp
    (map safe-parse-json)
    (filter (fn [t] (-> t :text str/lower-case contains-profanity?)))))

(defn turbine-topology-vector [elastic-url]
  (let [es-conn (esr/connect elastic-url)]

    ;; This is the 'error' function for the callback. It has a response and
    ;; a throwable.
    (fn [err thr] (binding [*out* *err*] 
      (println "ERROR:" err)))))

;;;; PROCESSING HELPERS ;;;;
(defn contains-profanity? [text]
