Uses of Interface
org.redisson.api.stream.StreamReadArgs
-
Packages that use StreamReadArgs Package Description org.redisson org.redisson.api org.redisson.api.stream -
-
Uses of StreamReadArgs in org.redisson
Methods in org.redisson with parameters of type StreamReadArgs Modifier and Type Method Description Map<StreamMessageId,Map<K,V>>
RedissonStream. read(StreamReadArgs args)
RFuture<Map<StreamMessageId,Map<K,V>>>
RedissonStream. readAsync(StreamReadArgs args)
-
Uses of StreamReadArgs in org.redisson.api
Methods in org.redisson.api with parameters of type StreamReadArgs Modifier and Type Method Description Map<StreamMessageId,Map<K,V>>
RStream. read(StreamReadArgs args)
Read stream data from current stream only.reactor.core.publisher.Mono<Map<StreamMessageId,Map<K,V>>>
RStreamReactive. read(StreamReadArgs args)
Read stream data from current stream only.io.reactivex.rxjava3.core.Single<Map<StreamMessageId,Map<K,V>>>
RStreamRx. read(StreamReadArgs args)
Read stream data from current stream only.RFuture<Map<StreamMessageId,Map<K,V>>>
RStreamAsync. readAsync(StreamReadArgs args)
Read stream data from current stream only. -
Uses of StreamReadArgs in org.redisson.api.stream
Methods in org.redisson.api.stream that return StreamReadArgs Modifier and Type Method Description StreamReadArgs
StreamReadArgs. count(int count)
Defines stream data size limit.static StreamReadArgs
StreamReadArgs. greaterThan(StreamMessageId id0)
Defines last stream id received from current Stream.StreamReadArgs
StreamReadArgs. timeout(Duration timeout)
Defines time interval to wait for stream data availability.
-