Class ObservableOnSubscribeAdapter<T>

    • Field Detail

      • subRef

        protected final AtomicReference<io.vertx.rx.java.ObservableOnSubscribeAdapter.SingleSubscription> subRef
    • Constructor Detail

      • ObservableOnSubscribeAdapter

        public ObservableOnSubscribeAdapter()
    • Method Detail

      • 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