 
 (def catalog
   [{:onyx/name :colors-in
-    :onyx/ident :core.async/read-from-chan
+    :onyx/plugin :onyx.plugin.core-async/input
     :onyx/type :input
     :onyx/medium :core.async
     :onyx/batch-size batch-size


    (try
      (f)

      (finally
        (component/stop system)
        (webdriver/quit)))))

    :onyx/batch-size batch-size}

   {:onyx/name :red-out
    :onyx/plugin :onyx.plugin.core-async/output
    :onyx/type :output
    :onyx/medium :core.async
    :onyx/batch-size batch-size
