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 |
---|---|
reactor.core.publisher.Flux<ChannelMessage<K,V>> |
RedisPubSubReactiveCommandsImpl.observeChannels() |
reactor.core.publisher.Flux<ChannelMessage<K,V>> |
RedisPubSubReactiveCommandsImpl.observeChannels(reactor.core.publisher.FluxSink.OverflowStrategy overflowStrategy) |
Modifier and Type | Method and Description |
---|---|
reactor.core.publisher.Flux<ChannelMessage<K,V>> |
RedisPubSubReactiveCommands.observeChannels()
Flux for messages (message) received though channel subscriptions.
|
reactor.core.publisher.Flux<ChannelMessage<K,V>> |
RedisPubSubReactiveCommands.observeChannels(reactor.core.publisher.FluxSink.OverflowStrategy overflowStrategy)
Flux for messages (message) received though channel subscriptions.
|
Copyright © 2018 lettuce.io. All rights reserved.