| Class | Description |
|---|---|
| BasicEmptyQueueSubscription |
Base class for empty, async-fuseable intermediate operators.
|
| BasicNonoSubscriber |
Basic subscriber that supports queue fusion and defaults onSubscribe, onNext and cancel.
|
| BasicRefNonoSubscriber<R> |
Basic subscriber that supports queue fusion, has an atomic reference and defaults onSubscribe, onNext and cancel.
|
| BasicRefQueueSubscription<T,R> |
Base class extending AtomicInteger (wip or request accounting) and QueueSubscription (fusion).
|
| Nono |
Represents the base reactive class with fluent API for Publisher-based,
no-item just onError or onComplete source.
|