Got rid of (unimplemented) process-specific commands (command-proc). Use inputs system instead

Author: richhickey

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)]