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. |