Package org.redisson.reactive
Class SetReactiveIterator<V>
- java.lang.Object
-
- org.redisson.reactive.SetReactiveIterator<V>
-
-
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 RFuture<ScanResult<Object>>
scanIterator(RedisClient client, long nextIterPos)
protected boolean
tryAgain()
-
-
-
Method Detail
-
accept
public void accept(reactor.core.publisher.FluxSink<V> emitter)
-
tryAgain
protected boolean tryAgain()
-
scanIterator
protected abstract RFuture<ScanResult<Object>> scanIterator(RedisClient client, long nextIterPos)
-
-