Package software.amazon.awssdk.utils.async
package software.amazon.awssdk.utils.async
-
ClassDescriptionAllows to send trailing data before invoking onComplete on the downstream subscriber.An implementation of
Subscriber
that storesByteBuffer
events it receives for retrieval.The result ofByteBufferStoringSubscriber.transferTo(ByteBuffer)
.DelegatingSubscriber<T,U> ASubscriber
that can invoke callbacks during various parts of the subscriber and subscription lifecycle.A publisher to which anInputStream
can be written.Adapts aSubscriber
to aInputStream
.Adapts aPublisher
to anOutputStream
.A simple implementation ofSubscriber
that requests data one at a time.APublisher
to which callers canSimplePublisher.send(Object)
messages, simplifying the process of implementing a publisher.An implementation ofSubscriber
that stores the events it receives for retrieval.An event stored for later retrieval by this subscriber.