public class SingleOnSubscribeAdapter<T> extends Object implements rx.Observable.OnSubscribe<T>
| Modifier and Type | Field and Description |
|---|---|
protected AtomicReference<io.vertx.rx.java.SingleOnSubscribeAdapter.SingleSubscription> |
subRef |
| Constructor and Description |
|---|
SingleOnSubscribeAdapter() |
| Modifier and Type | Method and Description |
|---|---|
void |
call(rx.Subscriber<? super T> sub)
Subscription
|
protected void |
fireComplete()
Fire completed to active observer
|
protected void |
fireError(Throwable t)
Fire error to active observer
|
protected void |
fireNext(T next)
Fire next to active observer
|
protected void |
fireResult(T res)
Fire result to active observer
|
protected rx.Subscriber<? super T> |
getSubscriber()
Get subscriber
|
protected void |
onSubscribed() |
protected void |
onUnsubscribed() |
protected final AtomicReference<io.vertx.rx.java.SingleOnSubscribeAdapter.SingleSubscription> subRef
public void call(rx.Subscriber<? super T> sub)
call in interface rx.functions.Action1<rx.Subscriber<? super T>>protected void onSubscribed()
protected void onUnsubscribed()
protected final void fireNext(T next)
protected final void fireResult(T res)
protected void fireComplete()
protected void fireError(Throwable t)
protected rx.Subscriber<? super T> getSubscriber()
Copyright © 2015. All rights reserved.