Skip to content

Commit

Permalink
[streams] fix tests
Browse files Browse the repository at this point in the history
  • Loading branch information
Iван committed Dec 23, 2023
1 parent f499d5c commit 5b8548f
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -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(3000),
XReadParams.xReadParams().block(10000),
ImmutableMap.of("s", StreamEntryID.LAST_ENTRY)
);

Expand Down

0 comments on commit 5b8548f

Please sign in to comment.