MAke sure we wait for the check so it does not fail on the slower pip…

…eline (redis#2844)
thachlp · Jun 22, 2024 · 9781769 · 9781769
1 parent c1d213c
commit 9781769
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/src/test/java/io/lettuce/core/RedisClientIntegrationTests.java b/src/test/java/io/lettuce/core/RedisClientIntegrationTests.java
@@ -139,7 +139,10 @@ void shouldPropagateCommandTimeoutToCommandListener() throws InterruptedExceptio
         assertThat(commandListener.succeeded).isEmpty();
 
         Wait.untilTrue(() -> commandListener.failed.size() == 1);
-        assertThat(commandListener.failed).extracting(it -> it.getCommand().getType()).contains(CommandType.BLPOP);
+        Wait.untilTrue(() ->
+                commandListener.failed.stream().anyMatch(command ->
+                        command.getCommand().getType().equals(CommandType.BLPOP)));
+
 
         FastShutdown.shutdown(client);
     }