Package org.redisson.reactive

Class IteratorConsumer<V>

java.lang.Object

org.redisson.reactive.IteratorConsumer<V>

All Implemented Interfaces:

LongConsumer

public abstract class IteratorConsumer<V>
extends Object
implements LongConsumer

Author:

Nikita Koksharov

Constructor Summary

Constructors

Constructor	Description
IteratorConsumer(reactor.core.publisher.FluxSink<V> emitter)

Method Summary

Modifier and Type	Method	Description
void	accept(long value)
protected void	nextValues(reactor.core.publisher.FluxSink<V> emitter)
protected abstract RFuture<ScanResult<Object>>	scanIterator(RedisClient client, long nextIterPos)
protected Object	transformValue(Object value)
protected abstract boolean	tryAgain()

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.util.function.LongConsumer

andThen

Constructor Detail

IteratorConsumer

public IteratorConsumer(reactor.core.publisher.FluxSink<V> emitter)

Method Detail

accept

public void accept(long value)

Specified by:

accept in interface LongConsumer

nextValues

protected void nextValues(reactor.core.publisher.FluxSink<V> emitter)

transformValue

protected Object transformValue(Object value)

tryAgain

protected abstract boolean tryAgain()

scanIterator

protected abstract RFuture<ScanResult<Object>> scanIterator(RedisClient client,
                                                            long nextIterPos)