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

Class ChecksumCalculatingAsyncRequestBody.OnNextGuaranteedSubscriber

java.lang.Object

software.amazon.awssdk.utils.async.DelegatingSubscriber<ByteBuffer,ByteBuffer>

software.amazon.awssdk.core.internal.async.ChecksumCalculatingAsyncRequestBody.OnNextGuaranteedSubscriber

All Implemented Interfaces:

org.reactivestreams.Subscriber<ByteBuffer>

Enclosing class:

ChecksumCalculatingAsyncRequestBody

public static class ChecksumCalculatingAsyncRequestBody.OnNextGuaranteedSubscriber
extends DelegatingSubscriber<ByteBuffer,ByteBuffer>

Constructor Summary

Constructors

Constructor	Description
OnNextGuaranteedSubscriber(org.reactivestreams.Subscriber<? super ByteBuffer> subscriber)

Method Summary

Modifier and Type	Method	Description
void	onComplete()
void	onNext(ByteBuffer t)

Methods inherited from class software.amazon.awssdk.utils.async.DelegatingSubscriber

onError, onSubscribe

Methods inherited from class java.lang.Object

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

Constructor Details

OnNextGuaranteedSubscriber

public OnNextGuaranteedSubscriber(org.reactivestreams.Subscriber<? super ByteBuffer> subscriber)

Method Details

onNext

public void onNext(ByteBuffer t)

onComplete

public void onComplete()

Specified by:

onComplete in interface org.reactivestreams.Subscriber<ByteBuffer>

Overrides:

onComplete in class DelegatingSubscriber<ByteBuffer,ByteBuffer>