Class ChecksumSubscriber

java.lang.Object
software.amazon.awssdk.http.auth.aws.internal.signer.io.ChecksumSubscriber
All Implemented Interfaces:
org.reactivestreams.Subscriber<ByteBuffer>
@SdkInternalApi public final class ChecksumSubscriber extends Object implements org.reactivestreams.Subscriber<ByteBuffer>
A subscriber that takes a collection of checksums, and updates each checksum when it receives data.

  • Constructor Details

    • ChecksumSubscriber

      public ChecksumSubscriber(Collection<? extends Checksum> consumers)

  • Method Details

    • onSubscribe

      public void onSubscribe(org.reactivestreams.Subscription subscription)
      Specified by:
      onSubscribe in interface org.reactivestreams.Subscriber<ByteBuffer>

    • onNext

      public void onNext(ByteBuffer byteBuffer)
      Specified by:
      onNext in interface org.reactivestreams.Subscriber<ByteBuffer>

    • onError

      public void onError(Throwable throwable)
      Specified by:
      onError in interface org.reactivestreams.Subscriber<ByteBuffer>

    • onComplete

      public void onComplete()
      Specified by:
      onComplete in interface org.reactivestreams.Subscriber<ByteBuffer>

    • completeFuture

      public CompletableFuture<org.reactivestreams.Publisher<ByteBuffer>> completeFuture()