Package software.amazon.awssdk.core.internal.async

Class ChecksumValidatingPublisher

java.lang.Object

software.amazon.awssdk.core.internal.async.ChecksumValidatingPublisher

All Implemented Interfaces:

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

public final class ChecksumValidatingPublisher
extends Object
implements SdkPublisher<ByteBuffer>

Publisher to update the checksum as it reads the data and finally compares the computed checksum with expected Checksum.

Constructor Summary

Constructors

Constructor	Description
ChecksumValidatingPublisher(org.reactivestreams.Publisher<ByteBuffer> publisher, SdkChecksum sdkChecksum, String expectedChecksum)

Method Summary

Modifier and Type	Method	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

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

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

Specified by:

subscribe in interface org.reactivestreams.Publisher<ByteBuffer>