public abstract class BaseSubscription<T> extends Object implements Subscribable<T>
Modifier | Constructor and Description |
---|---|
|
BaseSubscription(DisposingExecutor fiber) |
protected |
BaseSubscription(DisposingExecutor fiber,
Filter<T> _filter) |
Modifier and Type | Method and Description |
---|---|
DisposingExecutor |
getQueue() |
void |
onMessage(T msg)
Receives the event, filters, and passes to handler.
|
protected abstract void |
onMessageOnProducerThread(T msg) |
public BaseSubscription(DisposingExecutor fiber)
protected BaseSubscription(DisposingExecutor fiber, Filter<T> _filter)
public DisposingExecutor getQueue()
getQueue
in interface Subscribable<T>
public void onMessage(T msg)
protected abstract void onMessageOnProducerThread(T msg)
Copyright © 2017. All Rights Reserved.