Merge branch 'master' into dev-vthreads-exec

Author: puredanger

README.md

@@ -65,7 +65,7 @@ Copyright © Rich Hickey and contributors
 
 ## Changelog
 
-* Release 1.7.735 on 2025.04.02
+* Release 1.8.735 on 2025.04.02
   * Fix reflection warnings when using `clojure.core.async.go-checking`
 * Release 1.8.730 on 2025.04.02, effective changes since last non-beta release:
   * [ASYNC-256](https://clojure.atlassian.net/browse/ASYNC-256) (CLJ) Add `io-thread` and System property `clojure.core.async.executor-factory`

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

@@ -134,12 +134,6 @@
   "like ping, but just pings the specified process"
   [g pid & {:keys [timeout-ms] :or {timeout-ms 1000}}]
   (g/ping-proc g pid timeout-ms))
-
-(defn command-proc
-  "synchronously sends a process-specific command with the given id and
-  additional kvs to the process. The cmd-id must be ns-qualified with
-  a ns you own."
-  [g pid cmd-id more-kvs] (g/command-proc g pid cmd-id more-kvs))
 
 (defn inject
   "asynchronously puts the messages on the channel corresponding to the

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

@@ -166,16 +166,9 @@
       (pause [_] (send-command ::flow/pause ::flow/all))
       (resume [_] (send-command ::flow/resume ::flow/all))
       (ping [_ timeout-ms] (handle-ping ::flow/all timeout-ms))
-
       (pause-proc [_ pid] (send-command ::flow/pause pid))
       (resume-proc [_ pid] (send-command ::flow/resume pid))
-      (ping-proc [_ pid timeout-ms] (handle-ping pid timeout-ms))
-      (command-proc [_ pid command kvs]
-        (assert (and (namespace command) (not= (namespace ::flow/command) (namespace command)))
-                "extension commands must be in your own namespace")
-        (let [{:keys [control]} (running-chans)]
-          (async/>!! control (merge kvs #::flow{:command command :to pid}))))
-          
+      (ping-proc [_ pid timeout-ms] (handle-ping pid timeout-ms))         
       (inject [_ coord msgs]
         (let [{:keys [resolver]} (running-chans)
               chan (spi/get-write-chan resolver coord)]