Skip to content

Commit 1bc0f1f

Browse files
denglimingsazzad16
authored andcommitted
Fix xrevrange in PipelineBase (#2436)
1 parent af9e908 commit 1bc0f1f

File tree

2 files changed

+12
-6
lines changed

2 files changed

+12
-6
lines changed

src/main/java/redis/clients/jedis/PipelineBase.java

Lines changed: 7 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -1997,15 +1997,16 @@ public Response<List<byte[]>> xrange(byte[] key, byte[] start, byte[] end, int c
19971997
}
19981998

19991999
@Override
2000-
public Response<List<StreamEntry>> xrevrange(String key, StreamEntryID end, StreamEntryID start, int count){
2001-
getClient(key).xrevrange(key, start, end, count);
2002-
return getResponse(BuilderFactory.STREAM_ENTRY_LIST);
2000+
public Response<List<StreamEntry>> xrevrange(String key, StreamEntryID end, StreamEntryID start,
2001+
int count) {
2002+
getClient(key).xrevrange(key, end, start, count);
2003+
return getResponse(BuilderFactory.STREAM_ENTRY_LIST);
20032004
}
20042005

20052006
@Override
2006-
public Response<List<byte[]>> xrevrange(byte[] key, byte[] end, byte[] start, int count){
2007-
getClient(key).xrevrange(key, start, end, count);
2008-
return getResponse(BuilderFactory.BYTE_ARRAY_LIST);
2007+
public Response<List<byte[]>> xrevrange(byte[] key, byte[] end, byte[] start, int count) {
2008+
getClient(key).xrevrange(key, end, start, count);
2009+
return getResponse(BuilderFactory.BYTE_ARRAY_LIST);
20092010
}
20102011

20112012

src/test/java/redis/clients/jedis/tests/commands/StreamsCommandsTest.java

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -525,6 +525,11 @@ public void pipeline() {
525525
assertEquals(map, entries.get(0).getFields());
526526
assertEquals(id2.get(), entries.get(1).getID());
527527
assertEquals(map, entries.get(1).getFields());
528+
529+
p = jedis.pipelined();
530+
Response<List<StreamEntry>> results2 = p.xrevrange("stream1", null, id1.get(), 2);
531+
p.sync();
532+
assertEquals(2, results2.get().size());
528533
}
529534

530535
@Test

0 commit comments

Comments
 (0)