From c1ff36399093795c9024cfb08724ea3c499330ab Mon Sep 17 00:00:00 2001 From: Johno Crawford Date: Wed, 19 Aug 2020 22:20:20 +0200 Subject: [PATCH] return list type to allow accessing array by index. Signed-off-by: Johno Crawford --- .../src/main/java/org/redisson/RedissonScoredSortedSet.java | 4 ++-- redisson/src/main/java/org/redisson/api/RScoredSortedSet.java | 2 +- .../src/main/java/org/redisson/api/RScoredSortedSetAsync.java | 2 +- .../main/java/org/redisson/api/RScoredSortedSetReactive.java | 2 +- .../src/main/java/org/redisson/api/RScoredSortedSetRx.java | 2 +- 5 files changed, 6 insertions(+), 6 deletions(-) diff --git a/redisson/src/main/java/org/redisson/RedissonScoredSortedSet.java b/redisson/src/main/java/org/redisson/RedissonScoredSortedSet.java index 27517fb70..2b2608e42 100644 --- a/redisson/src/main/java/org/redisson/RedissonScoredSortedSet.java +++ b/redisson/src/main/java/org/redisson/RedissonScoredSortedSet.java @@ -409,7 +409,7 @@ public class RedissonScoredSortedSet extends RedissonExpirable implements RSc } @Override - public Collection getAllScore(List keys) { + public List getAllScore(List keys) { return get(getAllScoreAsync(keys)); } @@ -419,7 +419,7 @@ public class RedissonScoredSortedSet extends RedissonExpirable implements RSc } @Override - public RFuture> getAllScoreAsync(Collection elements) { + public RFuture> getAllScoreAsync(Collection elements) { return commandExecutor.evalReadAsync((String) null, DoubleCodec.INSTANCE, RedisCommands.EVAL_LIST, "local r = {} " + "for i, v in ipairs(ARGV) do " + diff --git a/redisson/src/main/java/org/redisson/api/RScoredSortedSet.java b/redisson/src/main/java/org/redisson/api/RScoredSortedSet.java index 021e4d98e..cec190009 100644 --- a/redisson/src/main/java/org/redisson/api/RScoredSortedSet.java +++ b/redisson/src/main/java/org/redisson/api/RScoredSortedSet.java @@ -269,7 +269,7 @@ public interface RScoredSortedSet extends RScoredSortedSetAsync, Iterable< * @param elements - elements * @return element scores */ - Collection getAllScore(List elements); + List getAllScore(List elements); /** * Adds element to this set, overrides previous score if it has been already added. diff --git a/redisson/src/main/java/org/redisson/api/RScoredSortedSetAsync.java b/redisson/src/main/java/org/redisson/api/RScoredSortedSetAsync.java index a82ba5c6b..2ae10eb1a 100644 --- a/redisson/src/main/java/org/redisson/api/RScoredSortedSetAsync.java +++ b/redisson/src/main/java/org/redisson/api/RScoredSortedSetAsync.java @@ -230,7 +230,7 @@ public interface RScoredSortedSetAsync extends RExpirableAsync, RSortableAsyn * @param elements - elements * @return element scores */ - RFuture> getAllScoreAsync(Collection elements); + RFuture> getAllScoreAsync(Collection elements); /** * Adds element to this set, overrides previous score if it has been already added. diff --git a/redisson/src/main/java/org/redisson/api/RScoredSortedSetReactive.java b/redisson/src/main/java/org/redisson/api/RScoredSortedSetReactive.java index e2122a904..4bea58935 100644 --- a/redisson/src/main/java/org/redisson/api/RScoredSortedSetReactive.java +++ b/redisson/src/main/java/org/redisson/api/RScoredSortedSetReactive.java @@ -242,7 +242,7 @@ public interface RScoredSortedSetReactive extends RExpirableReactive, RSortab * @param elements - elements * @return element scores */ - Mono> getAllScore(Collection elements); + Mono> getAllScore(Collection elements); /** * Adds element to this set, overrides previous score if it has been already added. diff --git a/redisson/src/main/java/org/redisson/api/RScoredSortedSetRx.java b/redisson/src/main/java/org/redisson/api/RScoredSortedSetRx.java index 54d723bdd..d045db9b9 100644 --- a/redisson/src/main/java/org/redisson/api/RScoredSortedSetRx.java +++ b/redisson/src/main/java/org/redisson/api/RScoredSortedSetRx.java @@ -243,7 +243,7 @@ public interface RScoredSortedSetRx extends RExpirableRx, RSortableRx> * @param elements - elements * @return element scores */ - Maybe> getAllScore(Collection elements); + Maybe> getAllScore(Collection elements); /** * Adds element to this set, overrides previous score if it has been already added.