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

…eline (#2844)
redis · Apr 30, 2024 · 21514ef · 21514ef
1 parent a91d701
commit 21514ef
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);
     }