Selective receive in test to avoid receiving wrong message

ninenines · Jan 23, 2023 · 9c0be06 · 9c0be06
1 parent ffa04a5
commit 9c0be06
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/test/ws_SUITE.erl b/test/ws_SUITE.erl
@@ -165,7 +165,11 @@ reply_to(Config) ->
 	Self = self(),
 	Frame = {text, <<"Hello!">>},
 	ReplyTo = spawn(fun() ->
-		{ConnPid, StreamRef} = receive Msg -> Msg after 1000 -> error(timeout) end,
+		{ConnPid, StreamRef} = receive
+			{C, S} when is_pid(C), is_reference(S) -> {C, S}
+		after 1000 ->
+			error(timeout)
+		end,
 		{upgrade, [<<"websocket">>], _} = gun:await(ConnPid, StreamRef),
 		Self ! {self(), ready},
 		{ws, Frame} = gun:await(ConnPid, StreamRef),