Merge branch 'master' into dev-io-thread

Author: fogus

deps.edn

@@ -1,6 +1,6 @@
 {:paths ["src/main/clojure"]
  :deps
- {org.clojure/tools.analyzer.jvm {:mvn/version "1.3.1"}}
+ {org.clojure/tools.analyzer.jvm {:mvn/version "1.3.2"}}
  :aliases
  {:cljs-test {:extra-deps {org.clojure/clojurescript {:mvn/version "1.11.132"}}
               :extra-paths ["src/main/clojure/cljs" "src/test/cljs"]}

pom.xml

@@ -44,7 +44,7 @@
     <dependency>
       <groupId>org.clojure</groupId>
       <artifactId>tools.analyzer.jvm</artifactId>
-      <version>1.3.1</version>
+      <version>1.3.2</version>
     </dependency>
   </dependencies>
 

project.clj

@@ -5,7 +5,7 @@
             :url "http://www.eclipse.org/legal/epl-v10.html"}
   :parent [org.clojure/pom.contrib "1.2.0"]
   :dependencies [[org.clojure/clojure "1.11.4"]
-                 [org.clojure/tools.analyzer.jvm "1.3.1"]
+                 [org.clojure/tools.analyzer.jvm "1.3.2"]
                  [org.clojure/clojurescript "1.11.132" :scope "provided"]]
   :global-vars {*warn-on-reflection* true}
   :source-paths ["src/main/clojure"]

src/main/clojure/clojure/core/async/flow.clj

@@ -133,8 +133,9 @@
   [g pid cmd-id more-kvs] (g/command-proc g pid cmd-id more-kvs))
 
 (defn inject
-  "synchronously puts the messages on the channel corresponding to the
-  input or output of the process"
+  "asynchronously puts the messages on the channel corresponding to the
+  input or output of the process, returning a future that will
+  complete when done."
   [g [pid io-id :as coord] msgs] (g/inject g coord msgs))
 
 (defn process

src/main/clojure/clojure/core/async/flow/impl.clj

@@ -79,7 +79,7 @@
                        (let [{:keys [control]} (running-chans)]
                          (async/>!! control #::flow{:command command :to to})))]
     (reify
-     clojure.core.async.flow.impl.graph.Graph
+      clojure.core.async.flow.impl.graph.Graph
       (start [_]
         (.lock lock)
         (try
@@ -170,8 +170,9 @@
       (inject [_ coord msgs]
         (let [{:keys [resolver]} (running-chans)
               chan (spi/get-write-chan resolver coord)]
-          (doseq [m msgs]
-            (async/>!! chan m)))))))
+          ((futurize #(doseq [m msgs]
+                        (async/>!! chan m))
+                     {:exec :io})))))))
 
 (defn handle-command
   [pid pong status cmd]