diff --git a/src/common/datomish/transact.cljc b/src/common/datomish/transact.cljc index 3c369ba7..81daefc8 100644 --- a/src/common/datomish/transact.cljc +++ b/src/common/datomish/transact.cljc @@ -648,8 +648,9 @@ (a/tap (:listener-mult conn) listener-sink) listener-sink) -(defn- -listen-chan [f] - (let [c (a/chan (a/sliding-buffer 10))] +(defn- -listen-chan + [f n] + (let [c (a/chan (a/dropping-buffer n))] (go-loop [] (when-let [v (