Signed-off-by: seakider <seakider@gmail.com>
@ -50,7 +50,6 @@ import org.redisson.rx.CommandRxBatchService;
import java.util.*;
import java.util.concurrent.CompletableFuture;
import java.util.concurrent.CompletionException;
import java.util.concurrent.CompletionStage;
import java.util.concurrent.TimeUnit;
import java.util.function.BiConsumer;
import java.util.function.Function;
@ -52,7 +52,7 @@ public abstract class BaseAsyncIterator<V, E> implements AsyncIterator<V> {
client = v.getRedisClient();
nextItPos = v.getPos();
lastIt = v.getValues().iterator();
if (nextItPos.equals("0")) {
if ("0".equals(nextItPos)) {
nextItPos = null;
}
result.complete(lastIt.hasNext());