Package io.servicetalk.concurrent.api.internal
-
Class Summary Class Description CloseableIteratorBufferAsInputStream ConnectableBufferOutputStream AnOutputStream
that can be connected to a sink such that any data written on theOutputStream
is eventually emitted to the connectedPublisher
PublisherSource.Subscriber
.ConnectablePayloadWriter<T> APayloadWriter
that can beconnected
to a sink such that any data written on thePayloadWriter
is eventually emitted to the connectedPublisher
PublisherSource.Subscriber
.OffloaderAwareExecutor AnExecutor
which is also aSignalOffloaderFactory
and hence can influence a specificSignalOffloader
used by thisExecutor
.SubscribableCompletable ACompletable
that is also aCompletableSource
and hence can be subscribed.SubscribablePublisher<T> APublisher
that is also aPublisherSource
and hence can be subscribed.SubscribableSingle<T> ASingle
that is also aSingleSource
and hence can be subscribed.