     (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?)))))
+    (filter 
+      (fn [t] 
+        (-> t
+            ;; Pull the text out, or an empty string. 
+            (:text "")
+            ;; Convert to lower case.
+            str/lower-case 
+            ;; Check for profanity.
+            contains-profanity?)))))
 
 (defn turbine-topology-vector [elastic-url]
   (let [es-conn (esr/connect elastic-url)]

    ;; but we need to deserialize to execute the filters.
    [:spread :input 
      [[:deser1 (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)))))

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