test: stabilize flaky test
This commit is contained in:
parent
f062517ccb
commit
bcbeadd4af
|
@ -1042,7 +1042,13 @@ assert_client_exit(Pid, v5, takenover) ->
|
||||||
%% @ref: MQTT 5.0 spec [MQTT-3.1.4-3]
|
%% @ref: MQTT 5.0 spec [MQTT-3.1.4-3]
|
||||||
?assertReceive({'EXIT', Pid, {disconnected, ?RC_SESSION_TAKEN_OVER, _}});
|
?assertReceive({'EXIT', Pid, {disconnected, ?RC_SESSION_TAKEN_OVER, _}});
|
||||||
assert_client_exit(Pid, v3, takenover) ->
|
assert_client_exit(Pid, v3, takenover) ->
|
||||||
?assertReceive({'EXIT', Pid, {shutdown, tcp_closed}}, 1_000, #{pid => Pid});
|
?assertReceive(
|
||||||
|
{'EXIT', Pid, {shutdown, Reason}} when
|
||||||
|
Reason =:= tcp_closed orelse
|
||||||
|
Reason =:= closed,
|
||||||
|
1_000,
|
||||||
|
#{pid => Pid}
|
||||||
|
);
|
||||||
assert_client_exit(Pid, v3, kicked) ->
|
assert_client_exit(Pid, v3, kicked) ->
|
||||||
?assertReceive({'EXIT', Pid, _}, 1_000, #{pid => Pid});
|
?assertReceive({'EXIT', Pid, _}, 1_000, #{pid => Pid});
|
||||||
assert_client_exit(Pid, v5, kicked) ->
|
assert_client_exit(Pid, v5, kicked) ->
|
||||||
|
|
Loading…
Reference in New Issue