yuanbiao
/
emqx
1
0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

test: make test case more stable, less flaky

This commit is contained in:
zmstone 2024-04-17 20:42:03 +02:00
parent 6ab2b004ed
commit 55941000c0
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
apps/emqx_bridge_pulsar/test/emqx_bridge_pulsar_connector_SUITE.erl
View File

@ -1235,7 +1235,7 @@ t_resilience(Config) ->
after 1_000 -> ct:fail("producer didn't stop!") after 1_000 -> ct:fail("producer didn't stop!")
end, end,
Consumed = lists:flatmap( Consumed = lists:flatmap(
fun(_) -> receive_consumed(5_000) end, lists:seq(1, NumProduced) fun(_) -> receive_consumed(10_000) end, lists:seq(1, NumProduced)
), ),
?assertEqual(NumProduced, length(Consumed)), ?assertEqual(NumProduced, length(Consumed)),
ExpectedPayloads = lists:map(fun integer_to_binary/1, lists:seq(1, NumProduced)), ExpectedPayloads = lists:map(fun integer_to_binary/1, lists:seq(1, NumProduced)),