fixed removeAll() for RedissonScoredSortedSetReactive

9 years ago · e470a1ff80
parent 6de8a1a311
commit e470a1ff80
1 changed files with 1 additions and 1 deletions
--- a/src/main/java/org/redisson/reactive/RedissonScoredSortedSetReactive.java
+++ b/src/main/java/org/redisson/reactive/RedissonScoredSortedSetReactive.java
@ -154,7 +154,7 @@ public class RedissonScoredSortedSetReactive<V> extends RedissonExpirableReactiv
    public Publisher<Boolean> removeAll(Collection<?> c) {
        return commandExecutor.evalWriteReactive(getName(), codec, new RedisCommand<Boolean>("EVAL", new BooleanReplayConvertor(), 4, ValueType.OBJECTS),
                        "local v = 0 " +
-                        "for i = 0, table.getn(ARGV), 1 do "
+                        "for i = 1, table.getn(ARGV), 1 do "
                            + "if redis.call('zrem', KEYS[1], ARGV[i]) == 1 "
                            + "then v = 1 end "
                        +"end "