[streams] fix tests

atp-mipt · Dec 23, 2023 · d1354c3 · d1354c3
1 parent 5b8548f
commit d1354c3
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/src/test/java/com/github/fppt/jedismock/comparisontests/streams/XReadTests.java b/src/test/java/com/github/fppt/jedismock/comparisontests/streams/XReadTests.java
@@ -86,7 +86,7 @@ void blockingXREADforStreamThatRanDry(Jedis jedis) throws ExecutionException, In
     void xaddWithDelShouldNotAwakeClient(Jedis jedis) throws ExecutionException, InterruptedException {
         Future<?> future = blockingThread.submit(() -> {
             List<Map.Entry<String, List<StreamEntry>>> data = blockedClient.xread(
-                    XReadParams.xReadParams().block(10000),
+                    XReadParams.xReadParams().block(20000),
                     ImmutableMap.of("s", StreamEntryID.LAST_ENTRY)
             );
 
@@ -118,7 +118,7 @@ void xaddWithDelShouldNotAwakeClient(Jedis jedis) throws ExecutionException, Int
     void xaddWithDelAndLpushShouldNotAwakeClient(Jedis jedis) throws ExecutionException, InterruptedException {
         Future<?> future = blockingThread.submit(() -> {
             List<Map.Entry<String, List<StreamEntry>>> data = blockedClient.xread(
-                    XReadParams.xReadParams().block(10000),
+                    XReadParams.xReadParams().block(20000),
                     ImmutableMap.of("s", StreamEntryID.LAST_ENTRY)
             );