From d1354c3a8b85d7f5beb7aebe651ac9e06079c78e Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?I=D0=B2=D0=B0=D0=BD?= <kalinin.is@phystech.edu>
Date: Sat, 23 Dec 2023 23:48:43 +0300
Subject: [PATCH] [streams] fix tests

---
 .../fppt/jedismock/comparisontests/streams/XReadTests.java    | 4 ++--
 1 file changed, 2 insertions(+), 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
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<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)
             );