From 547573e7eeaee8b07a5f238d9e16870eed75767b Mon Sep 17 00:00:00 2001
From: Nikita <abracham.mitchell@gmail.com>
Date: Thu, 7 Dec 2017 13:51:36 +0300
Subject: [PATCH] RedissonInputStream.seek method added

---
 .../main/java/org/redisson/RedissonBinaryStream.java   | 10 +++++++++-
 1 file changed, 9 insertions(+), 1 deletion(-)

diff --git a/redisson/src/main/java/org/redisson/RedissonBinaryStream.java b/redisson/src/main/java/org/redisson/RedissonBinaryStream.java
index ecea38ea2..1565b4dad 100644
--- a/redisson/src/main/java/org/redisson/RedissonBinaryStream.java
+++ b/redisson/src/main/java/org/redisson/RedissonBinaryStream.java
@@ -66,11 +66,19 @@ public class RedissonBinaryStream extends RedissonBucket<byte[]> implements RBin
         
     }
     
-    class RedissonInputStream extends InputStream {
+    public class RedissonInputStream extends InputStream {
 
         private int index;
         private int mark;
         
+        public void seek(long pos) {
+            if (pos >= 0 && pos < size()) {
+                index = (int) pos;
+            } else {
+                throw new IllegalStateException("size is " + size() + " but pos is " + pos);
+            }
+        }
+        
         @Override
         public long skip(long n) throws IOException {
             long k = size() - index;