clojure.core.async.flow.impl — org.clojure/core.async 1.9.808-alpha1

create-flow clj

(create-flow {:keys [procs conns mixed-exec io-exec compute-exec]})

see lib ns for docs

datafy clj

(datafy x)

futurize clj

(futurize f {:keys [exec]})

handle-command clj

(handle-command pid pong status cmd)

handle-transition clj

(handle-transition transition status nstatus state)

when transition, returns maybe new state

prep-proc clj

(prep-proc ret pid {:keys [proc args chan-opts] :or {chan-opts {}}})

proc clj

(proc step {:keys [workload compute-timeout-ms] :or {compute-timeout-ms 5000}})

see lib ns for docs

send-outputs clj

(send-outputs status
              state
              outputs
              outs
              resolver
              control
              handle-command
              transition)