diff --git a/test/emqx_broker_SUITE.erl b/test/emqx_broker_SUITE.erl index 66ed608f9..575832bf8 100644 --- a/test/emqx_broker_SUITE.erl +++ b/test/emqx_broker_SUITE.erl @@ -438,7 +438,7 @@ t_connect_client_never_negative({'end', _Config}) -> ok. wait_for_events(Action, Kinds) -> - wait_for_events(Action, Kinds, 100). + wait_for_events(Action, Kinds, 500). wait_for_events(Action, Kinds, Timeout) -> Predicate = fun(#{?snk_kind := K}) -> @@ -465,7 +465,7 @@ wait_for_stats(Action, Stats) -> false end, N = length(Stats), - Timeout = 100, + Timeout = 500, {ok, Sub} = snabbkaffe_collector:subscribe(Predicate, N, Timeout, 0), Res = Action(), case snabbkaffe_collector:receive_events(Sub) of