Package io.vertx.rx.java
Class ObservableOnSubscribeAdapter<T>
- java.lang.Object
-
- io.vertx.rx.java.ObservableOnSubscribeAdapter<T>
-
- All Implemented Interfaces:
Action
,Action1<Subscriber<? super T>>
,Function
,Observable.OnSubscribe<T>
- Direct Known Subclasses:
HandlerAdapter
public class ObservableOnSubscribeAdapter<T> extends Object implements Observable.OnSubscribe<T>
- Author:
- Julien Viet
-
-
Field Summary
Fields Modifier and Type Field Description protected AtomicReference<io.vertx.rx.java.ObservableOnSubscribeAdapter.SingleSubscription>
subRef
-
Constructor Summary
Constructors Constructor Description ObservableOnSubscribeAdapter()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
call(Subscriber<? super T> sub)
Subscriptionprotected void
fireComplete()
Fire completed to active observerprotected void
fireError(Throwable t)
Fire error to active observerprotected void
fireNext(T next)
Fire next to active observerprotected void
fireResult(T res)
Fire result to active observerprotected Subscriber<? super T>
getSubscriber()
Get subscriberprotected void
onSubscribed()
protected void
onUnsubscribed()
-
-
-
Field Detail
-
subRef
protected final AtomicReference<io.vertx.rx.java.ObservableOnSubscribeAdapter.SingleSubscription> subRef
-
-
Method Detail
-
call
public void call(Subscriber<? super T> sub)
Subscription
-
onSubscribed
protected void onSubscribed()
-
onUnsubscribed
protected void onUnsubscribed()
-
fireNext
protected final void fireNext(T next)
Fire next to active observer
-
fireResult
protected final void fireResult(T res)
Fire result to active observer
-
fireComplete
protected void fireComplete()
Fire completed to active observer
-
fireError
protected void fireError(Throwable t)
Fire error to active observer
-
getSubscriber
protected Subscriber<? super T> getSubscriber()
Get subscriber
-
-