io.servicetalk.concurrent.api.internal

Class Summary
Class	Description
CloseableIteratorBufferAsInputStream	Conversion from a `CloseableIterator` of `Buffer`s to a `InputStream`.
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`.
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.

Package io.servicetalk.concurrent.api.internal