Uses of Interface
org.redisson.api.stream.StreamPendingRangeArgs

Packages that use StreamPendingRangeArgs

Package	Description
org.redisson
org.redisson.api
org.redisson.api.stream

Uses of StreamPendingRangeArgs in org.redisson

Methods in org.redisson with parameters of type StreamPendingRangeArgs

Modifier and Type	Method	Description
List<PendingEntry>	RedissonStream.listPending(StreamPendingRangeArgs args)
RFuture<List<PendingEntry>>	RedissonStream.listPendingAsync(StreamPendingRangeArgs args)

Uses of StreamPendingRangeArgs in org.redisson.api

Methods in org.redisson.api with parameters of type StreamPendingRangeArgs

Modifier and Type	Method	Description
List<PendingEntry>	RStream.listPending(StreamPendingRangeArgs args)	Returns stream data of pending messages by group and customer name.
reactor.core.publisher.Mono<List<PendingEntry>>	RStreamReactive.listPending(StreamPendingRangeArgs args)	Returns list of common info about pending messages by group and consumer name.
io.reactivex.rxjava3.core.Single<List<PendingEntry>>	RStreamRx.listPending(StreamPendingRangeArgs args)	Returns list of common info about pending messages by group and consumer name.
RFuture<List<PendingEntry>>	RStreamAsync.listPendingAsync(StreamPendingRangeArgs args)	Returns list of common info about pending messages by group and consumer name.

Uses of StreamPendingRangeArgs in org.redisson.api.stream

Classes in org.redisson.api.stream that implement StreamPendingRangeArgs

Modifier and Type	Class	Description
class	StreamPendingRangeParams

Methods in org.redisson.api.stream that return StreamPendingRangeArgs

Modifier and Type	Method	Description
StreamPendingRangeArgs	StreamPendingRangeArgs.consumerName(String consumerName)	Defines consumerName of pending messages
StreamPendingRangeArgs	StreamPendingRangeParams.consumerName(String consumerName)
StreamPendingRangeArgs	StreamCountArgs.count(int count)	Defines messages count limit.
StreamPendingRangeArgs	StreamPendingRangeParams.count(int count)
StreamPendingRangeArgs	StreamPendingRangeArgs.idleTime(Duration idleTime)	Defines minimum idle time limit.
StreamPendingRangeArgs	StreamPendingRangeParams.idleTime(Duration idleTime)