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
Subscriberthat storesByteBufferevents it receives for retrieval.The result ofByteBufferStoringSubscriber.transferTo(ByteBuffer).DelegatingSubscriber<T,U> ASubscriberthat can invoke callbacks during various parts of the subscriber and subscription lifecycle.A publisher to which anInputStreamcan be written.Adapts aSubscriberto aInputStream.Adapts aPublisherto anOutputStream.A simple implementation ofSubscriberthat requests data one at a time.APublisherto which callers canSimplePublisher.send(Object)messages, simplifying the process of implementing a publisher.An implementation ofSubscriberthat stores the events it receives for retrieval.An event stored for later retrieval by this subscriber.