indexOfAsync refactoring

pull/243/head
Nikita 10 years ago
parent 03246b95d6
commit 334d7104dd

@ -357,7 +357,7 @@ public class RedissonList<V> extends RedissonExpirable implements RList<V> {
@Override @Override
public int indexOf(Object o) { public int indexOf(Object o) {
return get(indexOfAsync(o, new IntegerReplayConvertor())); return get(indexOfAsync(o));
} }
@Override @Override
@ -381,11 +381,7 @@ public class RedissonList<V> extends RedissonExpirable implements RList<V> {
@Override @Override
public Future<Integer> indexOfAsync(Object o) { public Future<Integer> indexOfAsync(Object o) {
return commandExecutor.evalReadAsync(getName(), new RedisCommand<Integer>("EVAL", new IntegerReplayConvertor(), 4), return indexOfAsync(o, new IntegerReplayConvertor());
"local s = redis.call('llen', KEYS[1]);" +
"for i = 0, s, 1 do if ARGV[1] == redis.call('lindex', KEYS[1], i) then return i end end;" +
"return -1",
Collections.<Object>singletonList(getName()), o);
} }
@Override @Override

Loading…
Cancel
Save