Package org.redisson.reactive

Class IteratorConsumer<V>

org.redisson.reactive.IteratorConsumer<V>

All Implemented Interfaces:

public abstract class IteratorConsumer<V>
extends 
implements 

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 >>	scanIterator(RedisClient client, long nextIterPos)
protected	value)
protected abstract boolean	tryAgain()

Methods inherited from class java.lang.

, , , , , , , , , ,

Methods inherited from interface java.util.function.

Constructor Detail

IteratorConsumer

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

Method Detail

accept

public void accept(long value)

Specified by:

in interface

nextValues

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

transformValue

protected  transformValue( value)

tryAgain

protected abstract boolean tryAgain()

scanIterator

protected abstract >> scanIterator(RedisClient client,
                                                            long nextIterPos)