We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 313569a commit 3ee4a34Copy full SHA for 3ee4a34
.gitignore
@@ -28,3 +28,4 @@ pom.xml.versionsBackup
28
.classpath
29
ccw.repl.cmdhistory.prefs
30
nbactions.xml
31
+.DS_Store
src/main/clojure/clojure/core/async/flow/impl.clj
@@ -202,8 +202,9 @@
202
(loop [nstatus nstatus, nstate nstate, msgs (seq msgs)]
203
(if (or (nil? msgs) (= nstatus :exit))
204
[nstatus nstate]
205
- (let [[v c] (async/alts!!
206
- [control [outc (first msgs)]]
+ (let [m (if-some [m (first msgs)] m (throw "messages must be non-nil"))
+ [v c] (async/alts!!
207
+ [control [outc m]]
208
:priority true)]
209
(if (= c control)
210
(let [nnstatus (handle-command nstatus v)
0 commit comments