handle last ch closed

clojure · May 7, 2014 · 8864214 · 8864214
1 parent 7632070
commit 8864214
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/main/clojure/clojure/core/async.clj b/src/main/clojure/clojure/core/async.clj
@@ -677,7 +677,7 @@
            (reset! dctr (count chs))
            (doseq [c chs]
              (when-not (put! c val done)
-               (swap! dctr dec)
+               (done nil)
                (untap* m c)))
            ;;wait for all
            (when (seq chs)