   [drivers]
   (->> drivers
        keys
-       (map (fn [name] [name (chan)]))
+       (map (fn [name] [name (chan 10)]))
        (into {})))
 
 (defn call-drivers

(defn weld-cycle!
  "Closes the cycle between the sinks and sink-proxies."
  [sink-chans sink-proxy-chans]
  (->> sink-chans
       (map (fn [[key sink-chan]]
              (when sink-chan
                (a/pipe sink-chan (key sink-proxy-chans)))))
       (dorun)))

(defn run
  "Cycle.run equivalent. Accepts a main function and a map of drivers."

(ns kierros.core
  "Cycle-flavoured core functions."
  (:require [cljs.core.async :as a :refer [<! chan close!]])
  (:require-macros [cljs.core.async.macros :refer [go]]))

(defn sink-proxies
  "Accepts a map of drivers. Returns a map of the equivalent of Rx.ReplaySubject instance
