| Package | Description |
|---|---|
| org.redisson | |
| org.redisson.api |
| Modifier and Type | Method and Description |
|---|---|
PendingResult |
RedissonStream.listPending(String groupName) |
| Modifier and Type | Method and Description |
|---|---|
RFuture<PendingResult> |
RedissonStream.listPendingAsync(String groupName) |
| Modifier and Type | Method and Description |
|---|---|
PendingResult |
RStream.listPending(String groupName)
Returns pending messages by group name
|
| Modifier and Type | Method and Description |
|---|---|
io.reactivex.Flowable<PendingResult> |
RStreamRx.listPending(String groupName)
Returns pending messages by group name
|
reactor.core.publisher.Mono<PendingResult> |
RStreamReactive.listPending(String groupName)
Returns pending messages by group name
|
RFuture<PendingResult> |
RStreamAsync.listPendingAsync(String groupName)
Returns pending messages by group name
|
Copyright © 2014–2018 The Redisson Project. All rights reserved.