Fix xrevrange in PipelineBase (#2436)

redis · Mar 15, 2021 · 1bc0f1f · 1bc0f1f
1 parent af9e908
commit 1bc0f1f
Show file tree

Hide file tree

Showing 2 changed files with 12 additions and 6 deletions.
diff --git a/src/main/java/redis/clients/jedis/PipelineBase.java b/src/main/java/redis/clients/jedis/PipelineBase.java
@@ -1997,15 +1997,16 @@ public Response<List<byte[]>> xrange(byte[] key, byte[] start, byte[] end, int c
   }
 
   @Override
-  public Response<List<StreamEntry>> xrevrange(String key, StreamEntryID end, StreamEntryID start, int count){
-    getClient(key).xrevrange(key, start, end, count);
-    return getResponse(BuilderFactory.STREAM_ENTRY_LIST);            
+  public Response<List<StreamEntry>> xrevrange(String key, StreamEntryID end, StreamEntryID start,
+      int count) {
+    getClient(key).xrevrange(key, end, start, count);
+    return getResponse(BuilderFactory.STREAM_ENTRY_LIST);
   }
 
   @Override
-  public Response<List<byte[]>> xrevrange(byte[] key, byte[] end, byte[] start, int count){
-    getClient(key).xrevrange(key, start, end, count);
-    return getResponse(BuilderFactory.BYTE_ARRAY_LIST);                
+  public Response<List<byte[]>> xrevrange(byte[] key, byte[] end, byte[] start, int count) {
+    getClient(key).xrevrange(key, end, start, count);
+    return getResponse(BuilderFactory.BYTE_ARRAY_LIST);
   }
 
 

diff --git a/src/test/java/redis/clients/jedis/tests/commands/StreamsCommandsTest.java b/src/test/java/redis/clients/jedis/tests/commands/StreamsCommandsTest.java
@@ -525,6 +525,11 @@ public void pipeline() {
     assertEquals(map, entries.get(0).getFields());
     assertEquals(id2.get(), entries.get(1).getID());
     assertEquals(map, entries.get(1).getFields());
+
+    p = jedis.pipelined();
+    Response<List<StreamEntry>> results2 = p.xrevrange("stream1", null, id1.get(), 2);
+    p.sync();
+    assertEquals(2, results2.get().size());
   }
 
   @Test