     ;; but we need to deserialize to execute the filters.
     [:spread :input 
       [[:deser1 (parse-filter)]
-      [:deser2 (parse-filter)]
-      [:deser3 (parse-filter)]]]
+       [:deser2 (parse-filter)]
+       [:deser3 (parse-filter)]]]
     ;; Unify all of the parsed values asynchronously.
     [:union [:deser1 :deser2 :deser3]
              [:to-out (map identity)]]

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

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

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