io.vertx.rx.java

## Class SingleOnSubscribeAdapter<T>

- java.lang.Object
- - io.vertx.rx.java.SingleOnSubscribeAdapter<T>

- All Implemented Interfaces:
    rx.functions.Action, rx.functions.Action1<rx.Subscriber<? super T>>, rx.functions.Function, rx.Observable.OnSubscribe<T>
  Direct Known Subclasses:
    ReadStreamAdapter

      public class SingleOnSubscribeAdapter<T>
      extends Object
      implements rx.Observable.OnSubscribe<T>

  Author:
    Julien Viet

- - ### Field Summary

    Fields
    Modifier and Type | Field and Description
    --- | ---
    `protected AtomicReference<io.vertx.rx.java.SingleOnSubscribeAdapter.SingleSubscription>` | `subRef`

  - ### Constructor Summary

    Constructors
    Constructor and Description
    `SingleOnSubscribeAdapter()`

  - ### Method Summary

    All Methods Instance Methods Concrete Methods
    Modifier and Type | Method and Description
    --- | ---
    `void` | `call(rx.Subscriber<? super T> sub)` Subscription
    `protected void` | `execute()`
    `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` | `onUnsubscribed()`

    - ### Methods inherited from class java.lang.Object

      `clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait`

- - ### Field Detail

    - #### subRef

          protected final AtomicReference<io.vertx.rx.java.SingleOnSubscribeAdapter.SingleSubscription> subRef

  - ### Constructor Detail

    - #### SingleOnSubscribeAdapter

          public SingleOnSubscribeAdapter()

  - ### Method Detail

    - #### call

          public void call(rx.Subscriber<? super T> sub)

      Subscription
      Specified by:
        `call` in interface `rx.functions.Action1<rx.Subscriber<? super T>>`

    - #### execute

          protected void execute()

    - #### 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 rx.Subscriber<? super T> getSubscriber()

      Get subscriber

Copyright © 2015. All Rights Reserved.