Package io.lettuce.core.output
Interface StreamingOutput<T>
-
- All Known Implementing Classes:
BooleanListOutput
,GeoCoordinatesListOutput
,GeoCoordinatesValueListOutput
,GeoWithinListOutput
,IntegerListOutput
,KeyListOutput
,KeyValueListOutput
,PendingMessageListOutput
,ScoredValueListOutput
,StreamMessageListOutput
,StreamReadOutput
,StringListOutput
,StringValueListOutput
,ValueListOutput
,ValueValueListOutput
public interface StreamingOutput<T>
Implementors of this class support a streamingCommandOutput
while the command is still processed. The receivingStreamingOutput.Subscriber
receivesStreamingOutput.Subscriber.onNext(Collection, Object)
calls while the command is active.- Since:
- 4.2
- Author:
- Mark Paluch
-
-
Nested Class Summary
Nested Classes Modifier and Type Interface Description static class
StreamingOutput.Subscriber<T>
Subscriber to aStreamingOutput
.
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description StreamingOutput.Subscriber<T>
getSubscriber()
Retrieves theStreamingOutput.Subscriber
.void
setSubscriber(StreamingOutput.Subscriber<T> subscriber)
Sets theStreamingOutput.Subscriber
.
-
-
-
Method Detail
-
setSubscriber
void setSubscriber(StreamingOutput.Subscriber<T> subscriber)
Sets theStreamingOutput.Subscriber
.- Parameters:
subscriber
-
-
getSubscriber
StreamingOutput.Subscriber<T> getSubscriber()
Retrieves theStreamingOutput.Subscriber
.- Returns:
-
-