Class ChecksumValidatingPublisher
java.lang.Object
software.amazon.awssdk.core.internal.async.ChecksumValidatingPublisher
- All Implemented Interfaces:
org.reactivestreams.Publisher<ByteBuffer>
,SdkPublisher<ByteBuffer>
Publisher to update the checksum as it reads the data and
finally compares the computed checksum with expected Checksum.
-
Constructor Summary
ConstructorDescriptionChecksumValidatingPublisher
(org.reactivestreams.Publisher<ByteBuffer> publisher, SdkChecksum sdkChecksum, String expectedChecksum) -
Method Summary
Modifier and TypeMethodDescriptionvoid
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
addTrailingData, buffer, doAfterOnCancel, doAfterOnComplete, doAfterOnError, filter, filter, flatMapIterable, limit, map, subscribe
-
Constructor Details
-
ChecksumValidatingPublisher
public ChecksumValidatingPublisher(org.reactivestreams.Publisher<ByteBuffer> publisher, SdkChecksum sdkChecksum, String expectedChecksum)
-
-
Method Details
-
subscribe
- Specified by:
subscribe
in interfaceorg.reactivestreams.Publisher<ByteBuffer>
-