From efa37ad84fb0ba0d81164d2e5e5bc01c8291a175 Mon Sep 17 00:00:00 2001 From: Sean Corfield Date: Fri, 26 Jun 2020 21:31:28 -0700 Subject: [PATCH] Use map for some interleaving of combine and join #125 --- src/next/jdbc/result_set.clj | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/next/jdbc/result_set.clj b/src/next/jdbc/result_set.clj index cc0d326..4bfcf88 100644 --- a/src/next/jdbc/result_set.clj +++ b/src/next/jdbc/result_set.clj @@ -623,7 +623,7 @@ (recur (conj batch (realize rs-map)) tasks)) (#'r/fjinvoke #(r/reduce combinef (combinef) - (mapv #'r/fjjoin (conj tasks (#'r/fjfork (chunk batch))))))))) + (map #'r/fjjoin (conj tasks (#'r/fjfork (chunk batch))))))))) (reducef (combinef) {:next.jdbc/update-count (.getUpdateCount stmt)}))) (defn- stmt-sql->result-set @@ -678,7 +678,7 @@ (recur (conj batch (realize rs-map)) tasks)) (#'r/fjinvoke #(r/reduce combinef (combinef) - (mapv #'r/fjjoin (conj tasks (#'r/fjfork (chunk batch))))))))) + (map #'r/fjjoin (conj tasks (#'r/fjfork (chunk batch))))))))) (reducef (combinef) {:next.jdbc/update-count (.getUpdateCount stmt)}))) (extend-protocol p/Executable