diff --git a/src/main/java/org/redisson/reactive/RedissonScoredSortedSetReactive.java b/src/main/java/org/redisson/reactive/RedissonScoredSortedSetReactive.java index 50af3b9a4..b600ab844 100644 --- 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 extends RedissonExpirableReactiv public Publisher removeAll(Collection c) { return commandExecutor.evalWriteReactive(getName(), codec, new RedisCommand("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 "