Class UnbufferedChecksumSubscriber

java.lang.Object
software.amazon.awssdk.http.auth.aws.internal.signer.io.UnbufferedChecksumSubscriber
All Implemented Interfaces:
org.reactivestreams.Subscriber<ByteBuffer>
@SdkInternalApi public class UnbufferedChecksumSubscriber extends Object implements org.reactivestreams.Subscriber<ByteBuffer>
A decorating Subscriber that updates a list of SdkChecksums with the data of each buffer given to onNext.

This is "unbuffered", as opposed to ChecksumSubscriber which does buffer the data. The buffered version is only used for non-streaming flexible checksums; since those payloads will not be very large, the buffering is acceptable.

  • Constructor Details

    • UnbufferedChecksumSubscriber

      public UnbufferedChecksumSubscriber(List<SdkChecksum> checksums, org.reactivestreams.Subscriber<? super ByteBuffer> wrapped)

  • 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>