Package | Description |
---|---|
io.lettuce.core.pubsub |
Pub/Sub connection classes.
|
io.lettuce.core.pubsub.api.reactive |
Pub/Sub Redis API for reactive command execution.
|
Modifier and Type | Method and Description |
---|---|
Flux<PatternMessage<K,V>> |
RedisPubSubReactiveCommandsImpl.observePatterns() |
Flux<PatternMessage<K,V>> |
RedisPubSubReactiveCommandsImpl.observePatterns(FluxSink.OverflowStrategy overflowStrategy) |
Modifier and Type | Method and Description |
---|---|
Flux<PatternMessage<K,V>> |
RedisPubSubReactiveCommands.observePatterns()
Flux for messages (pmessage) received though pattern subscriptions.
|
Flux<PatternMessage<K,V>> |
RedisPubSubReactiveCommands.observePatterns(FluxSink.OverflowStrategy overflowStrategy)
Flux for messages (pmessage) received though pattern subscriptions.
|
Copyright © 2017 lettuce.io. All rights reserved.