Package org.redisson.reactive

Class MapReactiveIterator<K,V,M>

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

Type Parameters:

K - key type

V - value type

M - entry type

All Implemented Interfaces:

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

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

Author:

Nikita Koksharov

Constructor Summary

Constructors

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

Method Summary

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

Methods inherited from class java.lang.

, , , , , , , , , ,

Methods inherited from interface java.util.function.

Constructor Detail

MapReactiveIterator

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

Method Detail

accept

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

Specified by:

in interface <K>

tryAgain

protected boolean tryAgain()

scanIterator

public >> scanIterator(RedisClient client,
                                                long nextIterPos)