refactoring

redisson/src/main/java/org/redisson/RedissonBinaryStream.java

@@ -66,8 +66,8 @@ public class RedissonBinaryStream extends RedissonBucket<byte[]> implements RBin
     
     class RedissonInputStream extends InputStream {
 
-        private int index;
-        private int mark;
+        private long index;
+        private long mark;
         
         @Override
         public long skip(long n) throws IOException {

redisson/src/main/java/org/redisson/command/RedisExecutor.java

@@ -286,7 +286,7 @@ public class RedisExecutor<V, R> {
                         || RedisCommands.BLOCKING_COMMANDS.contains(command))) {
             Long popTimeout = null;
             if (RedisCommands.BLOCKING_COMMANDS.contains(command)) {
-                for (int i = 0; i < params.length; i++) {
+                for (int i = 0; i < params.length-1; i++) {
                     if ("BLOCK".equals(params[i])) {
                         popTimeout = Long.valueOf(params[i+1].toString()) / 1000;
                         break;