Fix a race condition a socket would closed before a task started

mana-ethereum · Aug 31, 2018 · 88b1fd6 · 88b1fd6
1 parent 794ba21
commit 88b1fd6
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/test/websockex_test.exs b/test/websockex_test.exs
@@ -605,11 +605,16 @@ defmodule WebSockexTest do
       # Really glad that I got those sys behaviors now
       :sys.suspend(pid)
 
+      test_pid = self()
+
       task =
         Task.async(fn ->
+          send(test_pid, :task_started)
           WebSockex.send_frame(pid, {:text, "hello"})
         end)
 
+      assert_receive :task_started
+
       :gen_tcp.shutdown(conn.socket, :write)
 
       :sys.resume(pid)