Package io.lettuce.core.output
Class ListSubscriber<T>
- java.lang.Object
-
- io.lettuce.core.output.StreamingOutput.Subscriber<T>
-
- io.lettuce.core.output.ListSubscriber<T>
-
public class ListSubscriber<T> extends StreamingOutput.Subscriber<T>
- Since:
- 4.2
- Author:
- Mark Paluch, Julien Ruaux
-
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description static <T> ListSubscriber<T>
instance()
void
onNext(Collection<T> outputTarget, T t)
Data notification sent by theStreamingOutput
.void
onNext(T t)
Data notification sent by theStreamingOutput
.
-
-
-
Method Detail
-
instance
public static <T> ListSubscriber<T> instance()
-
onNext
public void onNext(T t)
Description copied from class:StreamingOutput.Subscriber
Data notification sent by theStreamingOutput
.- Specified by:
onNext
in classStreamingOutput.Subscriber<T>
- Parameters:
t
- element
-
onNext
public void onNext(Collection<T> outputTarget, T t)
Description copied from class:StreamingOutput.Subscriber
Data notification sent by theStreamingOutput
.- Overrides:
onNext
in classStreamingOutput.Subscriber<T>
- Parameters:
outputTarget
- targett
- element
-
-