prevent nil messages from messing up alts

clojure · Jan 16, 2025 · 3ee4a34 · 3ee4a34
1 parent 313569a
commit 3ee4a34
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 2 deletions.
diff --git a/.gitignore b/.gitignore
@@ -28,3 +28,4 @@ pom.xml.versionsBackup
 .classpath
 ccw.repl.cmdhistory.prefs
 nbactions.xml
+.DS_Store
diff --git a/src/main/clojure/clojure/core/async/flow/impl.clj b/src/main/clojure/clojure/core/async/flow/impl.clj
@@ -202,8 +202,9 @@
                 (loop [nstatus nstatus, nstate nstate, msgs (seq msgs)]
                   (if (or (nil? msgs) (= nstatus :exit))
                     [nstatus nstate]
-                    (let [[v c] (async/alts!!
-                                 [control [outc (first msgs)]]
+                    (let [m (if-some [m (first msgs)] m (throw "messages must be non-nil"))
+                          [v c] (async/alts!!
+                                 [control [outc m]]
                                  :priority true)]
                       (if (= c control)
                         (let [nnstatus (handle-command nstatus v)