|
38 | 38 | supply ids for processes, inputs, outputs etc. These should be
|
39 | 39 | keywords. When a namespaced keyword is required it is explicitly
|
40 | 40 | stated. This documentation refers to various keywords utilized by
|
41 |
| - the library itself as ::flow/xyz, weere ::flow is an alias for |
| 41 | + the library itself as ::flow/xyz, where ::flow is an alias for |
42 | 42 | clojure.core.async.flow
|
43 | 43 |
|
44 | 44 | A process is represented in the flow definition by an implementation
|
|
79 | 79 |
|
80 | 80 | (defn start
|
81 | 81 | "starts the entire flow from init values. The processes start paused.
|
82 |
| - Call resume or resume-proc to start flow. |
83 |
| - returns {::flow/report-chan - a core.async chan for reading |
84 |
| - ::flow/error-chan - a core.async chan for reading}" |
| 82 | + Call 'resume' or 'resume-proc' to start flow. returns a map with keys: |
| 83 | + |
| 84 | + ::flow/report-chan - a core.async chan for reading.'ping' reponses |
| 85 | + will show up here, as will any explicit ::flow/report outputs |
| 86 | + from :transform/:inject |
| 87 | + |
| 88 | + ::flow/error-chan - a core.async chan for reading. Any (and only) |
| 89 | + exceptions thrown anywhere on any thread inside a flow will appear |
| 90 | + in maps sent here. There will at least be a ::flow/ex entry with the |
| 91 | + exception, and may be additional keys for pid, state, status etc |
| 92 | + depending on the context of the error." |
85 | 93 | [g] (g/start g))
|
86 | 94 |
|
87 | 95 | (defn stop
|
|
99 | 107 |
|
100 | 108 | (defn ping
|
101 | 109 | "pings all processes, which will put their status and state on the
|
102 |
| - report channel" |
| 110 | + report channel returned from start" |
103 | 111 | [g] (g/ping g))
|
104 | 112 |
|
105 | 113 | (defn pause-proc
|
|
112 | 120 |
|
113 | 121 | (defn ping-proc
|
114 | 122 | "pings the process, which will put its status and state on the report
|
115 |
| - channel" |
| 123 | + channel returned from start" |
116 | 124 | [g pid] (g/ping-proc g pid))
|
117 | 125 |
|
118 | 126 | (defn command-proc
|
|
0 commit comments