   [component delay f]
   (let [[_ out] (io component)]
     (async/schedule-fixedrate-interval delay
-                                       #(>> out (f)))))
+                                       #(streams/>> out (f)))))

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



                                       processed-v#))))
          (hellhound.component/input component#))))}))

;; Helpers -------------------------------------------------
(defn get-config
  [component]
  (:config (:context component)))

;; IO helpers ----------------------------------------------
(defn io
