T
- Type of messages a subscription will be forpublic interface Subscriber<T>
Modifier and Type | Method and Description |
---|---|
Disposable |
subscribe(DisposingExecutor executor,
Callback<T> receive)
Subscribe to receive messages produced by this subscriber
|
Disposable |
subscribe(Subscribable<T> sub) |
Disposable subscribe(DisposingExecutor executor, Callback<T> receive)
executor
- DisposingExecutor
to use for invoking the callback upon message receipt.receive
- Callback
to invoke upon message receiptDisposable
that can be invoked to cancel this subscriptionDisposable subscribe(Subscribable<T> sub)
Copyright © 2017. All Rights Reserved.