close! channels created in defasync functions

erikprice · erikprice · commit f1598908d7d7 · 2015-01-13T18:03:30.000-05:00
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]
