Package io.servicetalk.concurrent.api.internal
@ElementsAreNonnullByDefault
package io.servicetalk.concurrent.api.internal
Internal utilities which leverage the concurrent API package.
-
ClassDescriptionCommon utility functions to unwrap
ExecutionException
from async operations.AnOutputStream
that can be connected to a sink such that any data written on theOutputStream
is eventually emitted to the connectedPublisher
PublisherSource.Subscriber
.APayloadWriter
that can beconnected
to a sink such that any data written on thePayloadWriter
is eventually emitted to the connectedPublisher
PublisherSource.Subscriber
.ACompletable
that is also aCompletableSource
and hence can be subscribed.APublisher
that is also aPublisherSource
and hence can be subscribed.ASingle
that is also aSingleSource
and hence can be subscribed.