AsyncEmitter

Type Parameters:

T - the value type to emit

All Superinterfaces:

Observer<T>

All Known Implementing Classes:

OnSubscribeFromAsync.BaseAsyncEmitter, OnSubscribeFromAsync.BufferAsyncEmitter, OnSubscribeFromAsync.DropAsyncEmitter, OnSubscribeFromAsync.ErrorAsyncEmitter, OnSubscribeFromAsync.LatestAsyncEmitter, OnSubscribeFromAsync.NoneAsyncEmitter, OnSubscribeFromAsync.NoOverflowBaseAsyncEmitter
```
@Experimental
public interface AsyncEmitter<T>
extends Observer<T>
```
Abstraction over a RxJava Subscriber that allows associating a resource with it and exposes the current number of downstream requested amount.
The onNext, onError and onCompleted methods should be called in a sequential manner, just like the Observer's methods. The other methods are threadsafe.

Nested Class Summary

Nested Classes
Modifier and Type	Interface	Description
`static class`	`AsyncEmitter.BackpressureMode`	Options to handle backpressure in the emitter.
`static interface`	`AsyncEmitter.Cancellable`	A functional interface that has a single close method that can throw.

Method Summary

All Methods Instance Methods Abstract Methods
Modifier and Type	Method	Description
`long`	`requested()`	The current outstanding request amount.
`void`	`setCancellation(AsyncEmitter.Cancellable c)`	Sets a Cancellable on this emitter; any previous Subscription or Cancellation will be unsubscribed/cancelled.
`void`	`setSubscription(Subscription s)`	Sets a Subscription on this emitter; any previous Subscription or Cancellation will be unsubscribed/cancelled.

Methods inherited from interface rx.Observer
onCompleted, onError, onNext

- Method Detail
  - setSubscription
```
void setSubscription(Subscription s)
```
    Sets a Subscription on this emitter; any previous Subscription or Cancellation will be unsubscribed/cancelled.
    
    Parameters:
    
    s - the subscription, null is allowed
  - setCancellation
```
void setCancellation(AsyncEmitter.Cancellable c)
```
    Sets a Cancellable on this emitter; any previous Subscription or Cancellation will be unsubscribed/cancelled.
    
    Parameters:
    
    c - the cancellable resource, null is allowed
  - requested
```
long requested()
```
    The current outstanding request amount.
    This method it threadsafe.
    
    Returns:
    
    the current outstanding request amount