Package org.redisson.iterator

Class BaseAsyncIterator<V,E>

java.lang.Object

org.redisson.iterator.BaseAsyncIterator<V,E>

All Implemented Interfaces:

AsyncIterator<V>

public abstract class BaseAsyncIterator<V,E>
extends Object
implements AsyncIterator<V>

Author:

seakider

Field Summary

Fields

Modifier and Type	Field	Description
protected RedisClient	client
protected String	nextItPos

Constructor Summary

Constructors

Constructor	Description
BaseAsyncIterator()

Method Summary

Modifier and Type	Method	Description
protected V	getValue(E entry)
CompletionStage<Boolean>	hasNext()	Returns true if more elements are available.
protected abstract RFuture<ScanResult<E>>	iterator(RedisClient client, String nextItPos)
CompletionStage<V>	next()	Returns next element or NoSuchElementException if no more elements available.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

nextItPos

protected String nextItPos

client

protected RedisClient client

Constructor Details

BaseAsyncIterator

public BaseAsyncIterator()

Method Details

hasNext

public CompletionStage<Boolean> hasNext()

Description copied from interface: AsyncIterator

Returns true if more elements are available.

NOTE: each invocation returns a new instance of CompletionStage

Specified by:

hasNext in interface AsyncIterator<V>

Returns:

true if more elements are available, otherwise false

next

public CompletionStage<V> next()

Description copied from interface: AsyncIterator

Returns next element or NoSuchElementException if no more elements available.

NOTE: each invocation returns a new instance of CompletionStage

Specified by:

next in interface AsyncIterator<V>

Returns:

next element or NoSuchElementException

iterator

protected abstract RFuture<ScanResult<E>> iterator(RedisClient client,
 String nextItPos)

getValue

protected V getValue(E entry)