public class ObservableOnSubscribeAdapter<T> extends Object implements Observable.OnSubscribe<T>
Modifier and Type | Field and Description |
---|---|
protected AtomicReference<io.vertx.rx.java.ObservableOnSubscribeAdapter.SingleSubscription> |
subRef |
Constructor and Description |
---|
ObservableOnSubscribeAdapter() |
Modifier and Type | Method and Description |
---|---|
void |
call(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 Subscriber<? super T> |
getSubscriber()
Get subscriber
|
protected void |
onSubscribed() |
protected void |
onUnsubscribed() |
protected final AtomicReference<io.vertx.rx.java.ObservableOnSubscribeAdapter.SingleSubscription> subRef
public void call(Subscriber<? super T> sub)
call
in interface Action1<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 Subscriber<? super T> getSubscriber()
Copyright © 2022 Eclipse. All rights reserved.