inject is now async, returns future

Author: richhickey

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]