From 334d7104dd915cee6a2db46b5518413f89e03e6b Mon Sep 17 00:00:00 2001 From: Nikita Date: Thu, 30 Jul 2015 11:19:47 +0300 Subject: [PATCH] indexOfAsync refactoring --- src/main/java/org/redisson/RedissonList.java | 8 ++------ 1 file changed, 2 insertions(+), 6 deletions(-) diff --git a/src/main/java/org/redisson/RedissonList.java b/src/main/java/org/redisson/RedissonList.java index 6525a5549..41d65037c 100644 --- a/src/main/java/org/redisson/RedissonList.java +++ b/src/main/java/org/redisson/RedissonList.java @@ -357,7 +357,7 @@ public class RedissonList extends RedissonExpirable implements RList { @Override public int indexOf(Object o) { - return get(indexOfAsync(o, new IntegerReplayConvertor())); + return get(indexOfAsync(o)); } @Override @@ -381,11 +381,7 @@ public class RedissonList extends RedissonExpirable implements RList { @Override public Future indexOfAsync(Object o) { - return commandExecutor.evalReadAsync(getName(), new RedisCommand("EVAL", new IntegerReplayConvertor(), 4), - "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.singletonList(getName()), o); + return indexOfAsync(o, new IntegerReplayConvertor()); } @Override