Package io.servicetalk.concurrent.api.internal

@ElementsAreNonnullByDefault package io.servicetalk.concurrent.api.internal

Internal utilities which leverage the concurrent API package.

Related Packages

Package	Description
io.servicetalk.concurrent.api	ServiceTalk concurrent APIs which follow Reactive Streams semantics.
io.servicetalk.concurrent.api.test	Utilities that help build tests when interacting with ServiceTalk concurrent APIs.

Classes

Class	Description
BlockingUtils	Common utility functions to unwrap ExecutionException from async operations.
CloseableIteratorBufferAsInputStream	Conversion from a CloseableIterator of Buffers 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.
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.