software.amazon.awssdk.services.s3.checksums

Class ChecksumValidatingPublisher

java.lang.Object

software.amazon.awssdk.services.s3.checksums.ChecksumValidatingPublisher

All Implemented Interfaces:

org.reactivestreams.Publisher<ByteBuffer>, SdkPublisher<ByteBuffer>

public class ChecksumValidatingPublisher
extends Object
implements SdkPublisher<ByteBuffer>

Constructor Summary

Constructors

Constructor and Description
ChecksumValidatingPublisher(org.reactivestreams.Publisher<ByteBuffer> publisher, SdkChecksum sdkChecksum, int contentLength)

Method Summary

Modifier and Type	Method and Description
void	subscribe(org.reactivestreams.Subscriber<? super ByteBuffer> s)

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface software.amazon.awssdk.core.async.SdkPublisher

adapt, buffer, filter, filter, flatMapIterable, limit, map, subscribe

Constructor Detail

ChecksumValidatingPublisher

public ChecksumValidatingPublisher(org.reactivestreams.Publisher<ByteBuffer> publisher,
                                   SdkChecksum sdkChecksum,
                                   int contentLength)

Method Detail

subscribe

public void subscribe(org.reactivestreams.Subscriber<? super ByteBuffer> s)

Specified by:

subscribe in interface org.reactivestreams.Publisher<ByteBuffer>