| Interface | Description |
|---|---|
| Completable |
Interface that exposes a callback to indicate when an operation has been completed.
|
| Emitter<T> |
Base interface for classes that emit data.
|
| Class | Description |
|---|---|
| CompletionAwareSubscriber<T> |
A
Subscriber that tracks completion state using a AtomicBoolean. |
| SingleThreadedBufferingSubscriber<T> |
A
Subscriber designed to be used by a single thread that buffers incoming data for the purposes of managing
back pressure. |
| TypedSubscriber<T> |
A subscriber that is aware of the target type.
|
| Enum | Description |
|---|---|
| SingleThreadedBufferingSubscriber.BackPressureState |
Back pressure state.
|