public class LastSubscriber<T> extends BaseSubscription<T>
Constructor and Description |
---|
LastSubscriber(Fiber context,
Callback<T> target,
Filter<T> filter,
int flushInterval,
TimeUnit timeUnit) |
LastSubscriber(Fiber context,
Callback<T> target,
int flushInterval,
TimeUnit timeUnit) |
Modifier and Type | Method and Description |
---|---|
protected void |
onMessageOnProducerThread(T msg) |
getQueue, onMessage
public LastSubscriber(Fiber context, Callback<T> target, Filter<T> filter, int flushInterval, TimeUnit timeUnit)
protected void onMessageOnProducerThread(T msg)
onMessageOnProducerThread
in class BaseSubscription<T>
Copyright © 2017. All Rights Reserved.