| Class | Description |
|---|---|
| CloseableIteratorBufferAsInputStream | |
| ConnectableBufferOutputStream |
An
OutputStream that can be connected to a sink such that any data written on the OutputStream is
eventually emitted to the connected Publisher PublisherSource.Subscriber. |
| ConnectablePayloadWriter<T> |
A
PayloadWriter that can be connected to a sink such that any data written on the
PayloadWriter is eventually emitted to the connected Publisher PublisherSource.Subscriber. |
| OffloaderAwareExecutor |
An
Executor which is also a SignalOffloaderFactory and hence can influence a specific
SignalOffloader used by this Executor. |
| SpScPublisherProcessor<T> |
A
Publisher that allows for signals to be directly injected via SpScPublisherProcessor.sendOnNext(Object),
SpScPublisherProcessor.sendOnComplete(), and SpScPublisherProcessor.sendOnError(Throwable). |
| SubscribableCompletable |
A
Completable that is also a CompletableSource and hence can be subscribed. |
| SubscribablePublisher<T> |
A
Publisher that is also a PublisherSource and hence can be subscribed. |
| SubscribableSingle<T> |
A
Single that is also a SingleSource and hence can be subscribed. |