Package | Description |
---|---|
com.lambdaworks.redis.output |
Implementation of different output protocols including the Streaming API.
|
Modifier and Type | Method and Description |
---|---|
StreamingOutput.Subscriber<String> |
StringListOutput.getSubscriber() |
StreamingOutput.Subscriber<GeoCoordinates> |
GeoCoordinatesListOutput.getSubscriber() |
StreamingOutput.Subscriber<T> |
StreamingOutput.getSubscriber()
Retrieves the
StreamingOutput.Subscriber . |
StreamingOutput.Subscriber<Boolean> |
BooleanListOutput.getSubscriber() |
StreamingOutput.Subscriber<V> |
ValueListOutput.getSubscriber() |
StreamingOutput.Subscriber<GeoWithin<V>> |
GeoWithinListOutput.getSubscriber() |
StreamingOutput.Subscriber<K> |
KeyListOutput.getSubscriber() |
StreamingOutput.Subscriber<ScoredValue<V>> |
ScoredValueListOutput.getSubscriber() |
Modifier and Type | Method and Description |
---|---|
void |
BooleanListOutput.setSubscriber(StreamingOutput.Subscriber<Boolean> subscriber) |
void |
GeoCoordinatesListOutput.setSubscriber(StreamingOutput.Subscriber<GeoCoordinates> subscriber) |
void |
GeoWithinListOutput.setSubscriber(StreamingOutput.Subscriber<GeoWithin<V>> subscriber) |
void |
KeyListOutput.setSubscriber(StreamingOutput.Subscriber<K> subscriber) |
void |
ScoredValueListOutput.setSubscriber(StreamingOutput.Subscriber<ScoredValue<V>> subscriber) |
void |
StringListOutput.setSubscriber(StreamingOutput.Subscriber<String> subscriber) |
void |
StreamingOutput.setSubscriber(StreamingOutput.Subscriber<T> subscriber)
Sets the
StreamingOutput.Subscriber . |
void |
ValueListOutput.setSubscriber(StreamingOutput.Subscriber<V> subscriber) |
Copyright © 2018 lettuce.io. All rights reserved.