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
All Methods Instance Methods Abstract Methods Concrete Methods Modifier and Type Method Description void
accept(reactor.core.publisher.FluxSink<V> emitter)
protected abstract >>
scanIterator(RedisClient client, long nextIterPos)
protected boolean
tryAgain()
-
-
-
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)
-
-