From e470a1ff80c018fe774ad1dd1e77273986ef90d5 Mon Sep 17 00:00:00 2001 From: jackygurui Date: Tue, 12 Apr 2016 00:43:50 +0100 Subject: [PATCH] fixed removeAll() for RedissonScoredSortedSetReactive --- .../org/redisson/reactive/RedissonScoredSortedSetReactive.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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 "