clojure.core.async.flow.impl.graph — org.clojure/core.async 1.9.829-alpha2

Graph clj protocol

resume clj

(resume g)

resumes a paused graph

ping clj

(ping g timeout-ms)

pings all processes, which will put their status and state on the report channel

pause-proc clj

(pause-proc g pid)

pauses a process

resume-proc clj

(resume-proc g pid)

resumes a process

command-proc clj

(command-proc g pid cmd-id more-kvs)

synchronously sends a process-specific command with the given id and additional kvs to the process

start clj

(start g)

starts the entire graph from init values. The processes start paused. Call resume-all or resume-proc to start flow. returns {:report-chan - a core.async chan for reading :error-chan - a core.async chan for reading}

stop clj

(stop g)

shuts down the graph, stopping all procs, can be started again

inject clj

(inject g [pid io-id] msgs)

synchronously puts the messages on the channel corresponding to the input or output of the process

pause clj

(pause g)

pauses a running graph

ping-proc clj

(ping-proc g pid timeout-ms)

pings the process, which will put its status and state on the report channel