ObservableOnSubscribeAdapter (Vert.x Stack

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

Constructors
Constructor and Description
`ObservableOnSubscribeAdapter()`

All Methods Instance Methods Concrete Methods
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

Constructor Detail
- ObservableOnSubscribeAdapter
```
public ObservableOnSubscribeAdapter()
```

protected final void fireNext(T next)

Fire next to active observer

protected final void fireResult(T res)

Fire result to active observer

fireComplete
```
protected void fireComplete()
```
Fire completed to active observer

protected void fireError(Throwable t)

Fire error to active observer

protected Subscriber<? super T> getSubscriber()

Get subscriber

Class ObservableOnSubscribeAdapter<T>