      (streams/consume
       (fn [v]
         (let [processed-v (f component v)]
-          (when processed-v
+          (if processed-v
             (streams/>> (output component) processed-v))))
       (input component)))})
 

           streams/<<!
           streams/>>!
           f))

  (:require
   [hellhound.streams :as streams]
   [hellhound.components.protocols :as impl]
   [hellhound.components.impl.persistent-map :as component-impl]
   [hellhound.logger :as logger]))


;; Public Functions ----------------------------------------
