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 index 7004908bd..23fbde420 100644 --- 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>> 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>> data = blockedClient.xread( - XReadParams.xReadParams().block(10000), + XReadParams.xReadParams().block(20000), ImmutableMap.of("s", StreamEntryID.LAST_ENTRY) );