Package org.redisson.reactive

Class SetReactiveIterator<V>

org.redisson.reactive.SetReactiveIterator<V>

Type Parameters:

V - value type

All Implemented Interfaces:

<reactor.core.publisher.FluxSink<V>>

public abstract class SetReactiveIterator<V>
extends 
implements <reactor.core.publisher.FluxSink<V>>

Author:

Nikita Koksharov

Constructor Summary

Constructors

Constructor	Description
SetReactiveIterator()

Method Summary

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

Methods inherited from class java.lang.

, , , , , , , , , ,

Methods inherited from interface java.util.function.

Constructor Detail

SetReactiveIterator

public SetReactiveIterator()

Method Detail

accept

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

Specified by:

in interface <V>

tryAgain

protected boolean tryAgain()

scanIterator

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