Package software.amazon.awssdk.utils.async
package software.amazon.awssdk.utils.async
-
ClassDescriptionAllows to send trailing data before invoking onComplete on the downstream subscriber.Base of subscribers that can adapt one type to another.An implementation of
Subscriberthat storesByteBufferevents it receives for retrieval.The result ofByteBufferStoringSubscriber.transferTo(ByteBuffer).Decorator subscriber that limits the number of bytes sent to the wrapped subscriber to at mostcontentLength.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.