Package org.redisson.reactive

Class MapReactiveIterator<K,V,M>

java.lang.Object

org.redisson.reactive.MapReactiveIterator<K,V,M>

Type Parameters:

K - key type

V - value type

M - entry type

All Implemented Interfaces:

Consumer<reactor.core.publisher.FluxSink<M>>

public class MapReactiveIterator<K,V,M>
extends Object
implements Consumer<reactor.core.publisher.FluxSink<M>>

Author:

Nikita Koksharov

Constructor Summary

Constructors

Constructor	Description
MapReactiveIterator(RedissonMap<K,V> map, String pattern, int count)

Method Summary

Modifier and Type	Method	Description
void	accept(reactor.core.publisher.FluxSink<M> emitter)
RFuture<ScanResult<Object>>	scanIterator(RedisClient client, long nextIterPos)
protected 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.Consumer

andThen

Constructor Detail

MapReactiveIterator

public MapReactiveIterator(RedissonMap<K,V> map,
                           String pattern,
                           int count)

Method Detail

accept

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

Specified by:

accept in interface Consumer<K>

tryAgain

protected boolean tryAgain()

scanIterator

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