return list type to allow accessing array by index.

Signed-off-by: Johno Crawford <johno.crawford@gmail.com>
pull/2982/head
Johno Crawford 5 years ago
parent 72c0ef0e19
commit c1ff363990
No known key found for this signature in database
GPG Key ID: 747B819B88FCAB8A

@ -409,7 +409,7 @@ public class RedissonScoredSortedSet<V> extends RedissonExpirable implements RSc
} }
@Override @Override
public Collection<Double> getAllScore(List<V> keys) { public List<Double> getAllScore(List<V> keys) {
return get(getAllScoreAsync(keys)); return get(getAllScoreAsync(keys));
} }
@ -419,7 +419,7 @@ public class RedissonScoredSortedSet<V> extends RedissonExpirable implements RSc
} }
@Override @Override
public RFuture<Collection<Double>> getAllScoreAsync(Collection<V> elements) { public RFuture<List<Double>> getAllScoreAsync(Collection<V> elements) {
return commandExecutor.evalReadAsync((String) null, DoubleCodec.INSTANCE, RedisCommands.EVAL_LIST, return commandExecutor.evalReadAsync((String) null, DoubleCodec.INSTANCE, RedisCommands.EVAL_LIST,
"local r = {} " + "local r = {} " +
"for i, v in ipairs(ARGV) do " + "for i, v in ipairs(ARGV) do " +

@ -269,7 +269,7 @@ public interface RScoredSortedSet<V> extends RScoredSortedSetAsync<V>, Iterable<
* @param elements - elements * @param elements - elements
* @return element scores * @return element scores
*/ */
Collection<Double> getAllScore(List<V> elements); List<Double> getAllScore(List<V> elements);
/** /**
* Adds element to this set, overrides previous score if it has been already added. * Adds element to this set, overrides previous score if it has been already added.

@ -230,7 +230,7 @@ public interface RScoredSortedSetAsync<V> extends RExpirableAsync, RSortableAsyn
* @param elements - elements * @param elements - elements
* @return element scores * @return element scores
*/ */
RFuture<Collection<Double>> getAllScoreAsync(Collection<V> elements); RFuture<List<Double>> getAllScoreAsync(Collection<V> elements);
/** /**
* Adds element to this set, overrides previous score if it has been already added. * Adds element to this set, overrides previous score if it has been already added.

@ -242,7 +242,7 @@ public interface RScoredSortedSetReactive<V> extends RExpirableReactive, RSortab
* @param elements - elements * @param elements - elements
* @return element scores * @return element scores
*/ */
Mono<Collection<Double>> getAllScore(Collection<V> elements); Mono<List<Double>> getAllScore(Collection<V> elements);
/** /**
* Adds element to this set, overrides previous score if it has been already added. * Adds element to this set, overrides previous score if it has been already added.

@ -243,7 +243,7 @@ public interface RScoredSortedSetRx<V> extends RExpirableRx, RSortableRx<Set<V>>
* @param elements - elements * @param elements - elements
* @return element scores * @return element scores
*/ */
Maybe<Collection<Double>> getAllScore(Collection<V> elements); Maybe<List<Double>> getAllScore(Collection<V> elements);
/** /**
* Adds element to this set, overrides previous score if it has been already added. * Adds element to this set, overrides previous score if it has been already added.

Loading…
Cancel
Save