Merge pull request alaisi#5 from erikprice/close-defasyncs

alaisi · alaisi · commit ee1031f1cda6 · 2015-01-15T22:36:49.000+02:00
close! channels created in defasync functions
diff --git a/src/postgres/async/impl.clj b/src/postgres/async/impl.clj
@@ -1,14 +1,16 @@
 (ns postgres.async.impl
   (:require [clojure.string :as string]
-            [clojure.core.async :refer [chan put! go]])
+            [clojure.core.async :refer [chan close! put! go]])
   (:import [java.util.function Consumer]
            [com.github.pgasync ResultSet]
            [com.github.pgasync.impl PgRow]))
 
 (defmacro defasync [name args]
   `(defn ~name [~@args]
      (let [c# (chan 1)]
-       (~(symbol (subs (str name) 1)) ~@args #(put! c# (or %2 %1)))
+       (~(symbol (subs (str name) 1)) ~@args #(do
+                                                (put! c# (or %2 %1))
+                                                (close! c#)))
        c#)))
 
 (defmacro consumer-fn [[param] body]
