Uses of Interface
com.ibm.cos.v2.core.async.SdkPublisher

Packages that use SdkPublisher

Package	Description
com.ibm.cos.v2.awscore.eventstream
com.ibm.cos.v2.core.async
com.ibm.cos.v2.core.async.listener
com.ibm.cos.v2.core.internal.async
com.ibm.cos.v2.core.pagination.async
com.ibm.cos.v2.services.s3.internal.checksums
com.ibm.cos.v2.services.s3.paginators
com.ibm.cos.v2.transfer.s3.internal

Uses of SdkPublisher in com.ibm.cos.v2.awscore.eventstream

Methods in com.ibm.cos.v2.awscore.eventstream with parameters of type SdkPublisher

Modifier and Type	Method and Description
void	EventStreamResponseHandlerFromBuilder.onEventStream(SdkPublisher<EventT> p)
void	EventStreamResponseHandler.onEventStream(SdkPublisher<EventT> publisher) Called when events are ready to be streamed.
void	RestEventStreamAsyncResponseTransformer.onStream(SdkPublisher<ByteBuffer> publisher)
void	EventStreamAsyncResponseTransformer.onStream(SdkPublisher<ByteBuffer> publisher)

Method parameters in com.ibm.cos.v2.awscore.eventstream with type arguments of type SdkPublisher

Modifier and Type	Method and Description
SubBuilderT	EventStreamResponseHandler.Builder.onEventStream(Consumer<SdkPublisher<EventT>> onSubscribe) Callback to invoke when the SdkPublisher is available.
SubBuilderT	DefaultEventStreamResponseHandlerBuilder.onEventStream(Consumer<SdkPublisher<EventT>> onSubscribe)
SubBuilderT	EventStreamResponseHandler.Builder.publisherTransformer(Function<SdkPublisher<EventT>,SdkPublisher<EventT>> publisherTransformer) Allows for optional transformation of the publisher of events before subscribing.
SubBuilderT	EventStreamResponseHandler.Builder.publisherTransformer(Function<SdkPublisher<EventT>,SdkPublisher<EventT>> publisherTransformer) Allows for optional transformation of the publisher of events before subscribing.
SubBuilderT	DefaultEventStreamResponseHandlerBuilder.publisherTransformer(Function<SdkPublisher<EventT>,SdkPublisher<EventT>> publisherTransformer)
SubBuilderT	DefaultEventStreamResponseHandlerBuilder.publisherTransformer(Function<SdkPublisher<EventT>,SdkPublisher<EventT>> publisherTransformer)

Uses of SdkPublisher in com.ibm.cos.v2.core.async

Subinterfaces of SdkPublisher in com.ibm.cos.v2.core.async

Modifier and Type	Interface and Description
interface	AsyncRequestBody Interface to allow non-blocking streaming of request content.

Classes in com.ibm.cos.v2.core.async that implement SdkPublisher

Modifier and Type	Class and Description
class	BlockingInputStreamAsyncRequestBody An implementation of AsyncRequestBody that allows performing a blocking write of an input stream to a downstream service.
class	BlockingOutputStreamAsyncRequestBody An implementation of AsyncRequestBody that allows performing a blocking write of an output stream to a downstream service.
class	ResponsePublisher<ResponseT extends SdkResponse> An SdkPublisher that publishes response body content and also contains a reference to the SdkResponse returned by the service.

Methods in com.ibm.cos.v2.core.async that return SdkPublisher

Modifier and Type	Method and Description
static <T> SdkPublisher<T>	SdkPublisher.adapt(org.reactivestreams.Publisher<T> toAdapt) Adapts a Publisher to SdkPublisher.
default SdkPublisher<T>	SdkPublisher.addTrailingData(Supplier<Iterable<T>> trailingDataSupplier) Creates a new publisher that emits trailing events provided by trailingDataSupplier in addition to the published events.
default SdkPublisher<List<T>>	SdkPublisher.buffer(int bufferSize) Buffers the events into lists of the given buffer size.
default SdkPublisher<T>	SdkPublisher.doAfterOnCancel(Runnable afterOnCancel) Add a callback that will be invoked after this publisher invokes Subscription.cancel().
default SdkPublisher<T>	SdkPublisher.doAfterOnComplete(Runnable afterOnComplete) Add a callback that will be invoked after this publisher invokes Subscriber.onComplete().
default SdkPublisher<T>	SdkPublisher.doAfterOnError(Consumer<Throwable> afterOnError) Add a callback that will be invoked after this publisher invokes Subscriber.onError(Throwable).
default <U extends T> SdkPublisher<U>	SdkPublisher.filter(Class<U> clzz) Filters published events to just those that are instances of the given class.
default SdkPublisher<T>	SdkPublisher.filter(Predicate<T> predicate) Filters published events to just those that match the given predicate.
default <U> SdkPublisher<U>	SdkPublisher.flatMapIterable(Function<T,Iterable<U>> mapper) Performs a mapping on the published events and creates a new publisher that emits the mapped events one by one.
static <T> SdkPublisher<T>	SdkPublisher.fromIterable(Iterable<T> iterable) Create an SdkPublisher from an Iterable.
default SdkPublisher<T>	SdkPublisher.limit(int limit) Limit the number of published events and cancel the subscription after that limit has been reached.
default <U> SdkPublisher<U>	SdkPublisher.map(Function<T,U> mapper) Perform a mapping on the published events.
SdkPublisher<AsyncResponseTransformer<ResponseT,ResponseT>>	AsyncResponseTransformer.SplitResult.publisher() The individual AsyncResponseTransformer will be available through the publisher returned by this method.
SdkPublisher<AsyncResponseTransformer<ResponseT,ResponseT>>	AsyncResponseTransformer.SplitResult.Builder.publisher()
default SdkPublisher<AsyncRequestBody>	AsyncRequestBody.split(AsyncRequestBodySplitConfiguration splitConfiguration) Converts this AsyncRequestBody to a publisher of AsyncRequestBodys, each of which publishes a specific portion of the original data, based on the provided AsyncRequestBodySplitConfiguration.
default SdkPublisher<AsyncRequestBody>	AsyncRequestBody.split(Consumer<AsyncRequestBodySplitConfiguration.Builder> splitConfiguration) This is a convenience method that passes an instance of the AsyncRequestBodySplitConfiguration builder, avoiding the need to create one manually via AsyncRequestBodySplitConfiguration.builder().

Methods in com.ibm.cos.v2.core.async with parameters of type SdkPublisher

Modifier and Type	Method and Description
void	AsyncResponseTransformer.onStream(SdkPublisher<ByteBuffer> publisher) Called when the response stream is ready.
AsyncResponseTransformer.SplitResult.Builder<ResponseT,ResultT>	AsyncResponseTransformer.SplitResult.Builder.publisher(SdkPublisher<AsyncResponseTransformer<ResponseT,ResponseT>> publisher) Sets the publisher publishing the individual AsyncResponseTransformer

Constructors in com.ibm.cos.v2.core.async with parameters of type SdkPublisher

Constructor and Description
ResponsePublisher(ResponseT response, SdkPublisher<ByteBuffer> publisher)

Uses of SdkPublisher in com.ibm.cos.v2.core.async.listener

Classes in com.ibm.cos.v2.core.async.listener that implement SdkPublisher

Modifier and Type	Class and Description
static class	AsyncRequestBodyListener.NotifyingAsyncRequestBody
static class	PublisherListener.NotifyingPublisher<T>

Methods in com.ibm.cos.v2.core.async.listener that return SdkPublisher

Modifier and Type	Method and Description
SdkPublisher<AsyncRequestBody>	AsyncRequestBodyListener.NotifyingAsyncRequestBody.split(AsyncRequestBodySplitConfiguration splitConfiguration)
SdkPublisher<AsyncRequestBody>	AsyncRequestBodyListener.NotifyingAsyncRequestBody.split(Consumer<AsyncRequestBodySplitConfiguration.Builder> splitConfiguration)
static <T> SdkPublisher<T>	PublisherListener.wrap(SdkPublisher<T> delegate, PublisherListener<T> listener) Wrap a SdkPublisher with a new one that will notify a PublisherListener of important events occurring.

Methods in com.ibm.cos.v2.core.async.listener with parameters of type SdkPublisher

Modifier and Type	Method and Description
void	AsyncResponseTransformerListener.NotifyingAsyncResponseTransformer.onStream(SdkPublisher<ByteBuffer> publisher)
default void	AsyncResponseTransformerListener.transformerOnStream(SdkPublisher<ByteBuffer> publisher) Invoked before AsyncResponseTransformer.onStream(SdkPublisher)
static <T> SdkPublisher<T>	PublisherListener.wrap(SdkPublisher<T> delegate, PublisherListener<T> listener) Wrap a SdkPublisher with a new one that will notify a PublisherListener of important events occurring.

Uses of SdkPublisher in com.ibm.cos.v2.core.internal.async

Classes in com.ibm.cos.v2.core.internal.async that implement SdkPublisher

Modifier and Type	Class and Description
class	ByteBuffersAsyncRequestBody An implementation of AsyncRequestBody for providing data from the supplied ByteBuffer array.
class	ChecksumCalculatingAsyncRequestBody Wrapper class to wrap an AsyncRequestBody.
class	ChecksumValidatingPublisher Publisher to update the checksum as it reads the data and finally compares the computed checksum with expected Checksum.
class	CompressionAsyncRequestBody Wrapper class to wrap an AsyncRequestBody.
class	EnvelopeWrappedSdkPublisher<T> Publisher implementation that wraps the content of another publisher in an envelope with an optional prefix (or header) and suffix (or footer).
class	FileAsyncRequestBody Implementation of AsyncRequestBody that reads data from a file.
class	InputStreamWithExecutorAsyncRequestBody A AsyncRequestBody that allows reading data off of an InputStream using a background ExecutorService.
class	SplittingPublisher Splits an AsyncRequestBody to multiple smaller AsyncRequestBodys, each of which publishes a specific portion of the original data.
class	SplittingTransformer<ResponseT,ResultT> Split a AsyncResponseTransformer into multiple ones, publishing them as a SdkPublisher.

Methods in com.ibm.cos.v2.core.internal.async that return SdkPublisher

Modifier and Type	Method and Description
static SdkPublisher<ByteBuffer>	SdkPublishers.envelopeWrappedPublisher(org.reactivestreams.Publisher<ByteBuffer> publisher, String envelopePrefix, String envelopeSuffix) Constructs an SdkPublisher that wraps a ByteBuffer publisher and inserts additional content that wraps the published content like an envelope.
SdkPublisher<AsyncResponseTransformer<ResponseT,ResponseT>>	DefaultAsyncResponseTransformerSplitResult.publisher() The individual AsyncResponseTransformer will be available through the publisher returned by this method.
SdkPublisher<AsyncResponseTransformer<ResponseT,ResponseT>>	DefaultAsyncResponseTransformerSplitResult.DefaultBuilder.publisher()
SdkPublisher<AsyncRequestBody>	FileAsyncRequestBodySplitHelper.split()
SdkPublisher<AsyncRequestBody>	FileAsyncRequestBody.split(AsyncRequestBodySplitConfiguration splitConfiguration)

Methods in com.ibm.cos.v2.core.internal.async with parameters of type SdkPublisher

Modifier and Type	Method and Description
void	PublisherAsyncResponseTransformer.onStream(SdkPublisher<ByteBuffer> publisher)
void	InputStreamResponseTransformer.onStream(SdkPublisher<ByteBuffer> publisher)
void	FileAsyncResponseTransformer.onStream(SdkPublisher<ByteBuffer> publisher)
void	ByteArrayAsyncResponseTransformer.onStream(SdkPublisher<ByteBuffer> publisher)
AsyncResponseTransformer.SplitResult.Builder<ResponseT,ResultT>	DefaultAsyncResponseTransformerSplitResult.DefaultBuilder.publisher(SdkPublisher<AsyncResponseTransformer<ResponseT,ResponseT>> publisher)

Uses of SdkPublisher in com.ibm.cos.v2.core.pagination.async

Classes in com.ibm.cos.v2.core.pagination.async that implement SdkPublisher

Modifier and Type	Class and Description
class	PaginatedItemsPublisher<ResponseT,ItemT> A publisher to request for a stream of paginated items.

Uses of SdkPublisher in com.ibm.cos.v2.services.s3.internal.checksums

Classes in com.ibm.cos.v2.services.s3.internal.checksums that implement SdkPublisher

Modifier and Type	Class and Description
class	S3ChecksumValidatingPublisher

Uses of SdkPublisher in com.ibm.cos.v2.services.s3.paginators

Classes in com.ibm.cos.v2.services.s3.paginators that implement SdkPublisher

Modifier and Type	Class and Description
class	ListBucketsPublisher Represents the output for the S3AsyncClient.listBucketsPaginator(com.ibm.cos.v2.services.s3.model.ListBucketsRequest) operation which is a paginated operation.
class	ListDirectoryBucketsPublisher Represents the output for the S3AsyncClient.listDirectoryBucketsPaginator(com.ibm.cos.v2.services.s3.model.ListDirectoryBucketsRequest) operation which is a paginated operation.
class	ListMultipartUploadsPublisher Represents the output for the S3AsyncClient.listMultipartUploadsPaginator(com.ibm.cos.v2.services.s3.model.ListMultipartUploadsRequest) operation which is a paginated operation.
class	ListObjectsV2Publisher Represents the output for the S3AsyncClient.listObjectsV2Paginator(com.ibm.cos.v2.services.s3.model.ListObjectsV2Request) operation which is a paginated operation.
class	ListObjectVersionsPublisher Represents the output for the S3AsyncClient.listObjectVersionsPaginator(com.ibm.cos.v2.services.s3.model.ListObjectVersionsRequest) operation which is a paginated operation.
class	ListPartsPublisher Represents the output for the S3AsyncClient.listPartsPaginator(com.ibm.cos.v2.services.s3.model.ListPartsRequest) operation which is a paginated operation.

Methods in com.ibm.cos.v2.services.s3.paginators that return SdkPublisher

Modifier and Type	Method and Description
SdkPublisher<Bucket>	ListDirectoryBucketsPublisher.buckets() Returns a publisher that can be used to get a stream of data.
SdkPublisher<Bucket>	ListBucketsPublisher.buckets() Returns a publisher that can be used to get a stream of data.
SdkPublisher<CommonPrefix>	ListObjectsV2Publisher.commonPrefixes() Returns a publisher that can be used to get a stream of data.
SdkPublisher<CommonPrefix>	ListObjectVersionsPublisher.commonPrefixes() Returns a publisher that can be used to get a stream of data.
SdkPublisher<CommonPrefix>	ListMultipartUploadsPublisher.commonPrefixes() Returns a publisher that can be used to get a stream of data.
SdkPublisher<S3Object>	ListObjectsV2Publisher.contents() Returns a publisher that can be used to get a stream of data.
SdkPublisher<DeleteMarkerEntry>	ListObjectVersionsPublisher.deleteMarkers() Returns a publisher that can be used to get a stream of data.
SdkPublisher<Part>	ListPartsPublisher.parts() Returns a publisher that can be used to get a stream of data.
SdkPublisher<MultipartUpload>	ListMultipartUploadsPublisher.uploads() Returns a publisher that can be used to get a stream of data.
SdkPublisher<ObjectVersion>	ListObjectVersionsPublisher.versions() Returns a publisher that can be used to get a stream of data.

Uses of SdkPublisher in com.ibm.cos.v2.transfer.s3.internal

Methods in com.ibm.cos.v2.transfer.s3.internal that return SdkPublisher

Modifier and Type	Method and Description
SdkPublisher<S3Object>	ListObjectsHelper.listS3ObjectsRecursively(ListObjectsV2Request firstRequest)