Package io.lettuce.core.output
Class StreamingOutput.Subscriber<T>
- java.lang.Object
-
- io.lettuce.core.output.StreamingOutput.Subscriber<T>
-
- Type Parameters:
T
-
- Direct Known Subclasses:
ListSubscriber
- Enclosing interface:
- StreamingOutput<T>
public abstract static class StreamingOutput.Subscriber<T> extends Object
Subscriber to aStreamingOutput
.
-
-
Constructor Summary
Constructors Constructor Description Subscriber()
-
Method Summary
All Methods Instance Methods Abstract Methods Concrete Methods Modifier and Type Method Description void
onNext(Collection<T> outputTarget, T t)
Data notification sent by theStreamingOutput
.abstract void
onNext(T t)
Data notification sent by theStreamingOutput
.
-
-
-
Method Detail
-
onNext
public abstract void onNext(T t)
Data notification sent by theStreamingOutput
.- Parameters:
t
- element
-
onNext
public void onNext(Collection<T> outputTarget, T t)
Data notification sent by theStreamingOutput
.- Parameters:
outputTarget
- targett
- element
-
-