Avoid race condition

immutant · Feb 6, 2015 · 017c713 · 017c713
1 parent abc972b
commit 017c713
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/web/src/immutant/web/sse.clj b/web/src/immutant/web/sse.clj
@@ -42,8 +42,7 @@
 
 (defn send!
   "Formats an event according to the SSE spec and sends it
-  via [[immutant.web.async/send!]] with an optional on-complete
-  callback"
+  via [[immutant.web.async/send!]]"
   ([ch event]
    (send! ch event nil))
   ([ch event options]

diff --git a/web/test/immutant/web/sse_test.clj b/web/test/immutant/web/sse_test.clj
@@ -58,5 +58,6 @@
     (.open client)
     (is (= :success (deref closed 5000 :fail)))
     (is (not (.isOpen client)))
-    (is (= ["5" "4" "3" "2" "1" :done "bye!"] @result))
+    (is (= ["5" "4" "3" "2" "1"] (take 5 @result)))
+    (is (= #{:done "bye!"} (set (drop 5 @result))))
     (stop server)))