Add buffers on channels.

This commit is contained in:
Alexander K. Hudek 2014-10-18 18:11:52 -04:00
parent b1550b1fc1
commit 7d61caea52
2 changed files with 4 additions and 4 deletions

View file

@ -1,4 +1,4 @@
(defproject views "0.4.0"
(defproject views "0.4.1"
:description "You underestimate the power of the SQL side"
:url "https://github.com/diligenceengine/views"

View file

@ -27,9 +27,9 @@
(defn init!
[{:keys [base-subscribed-views] :as conf} client-chan]
(let [subs (chan)
unsubs (chan)
control (chan)
(let [subs (chan 200)
unsubs (chan 200)
control (chan 200)
disconnects (filter< #(= :disconnect (:body %)) control)]
(sub client-chan :views.subscribe subs)
(sub client-chan :views.unsubscribe unsubs)