Package software.amazon.awssdk.services.s3.internal.multipart

Class UnknownContentLengthAsyncRequestBodySubscriber

java.lang.Object

software.amazon.awssdk.services.s3.internal.multipart.UnknownContentLengthAsyncRequestBodySubscriber

All Implemented Interfaces:

org.reactivestreams.Subscriber<CloseableAsyncRequestBody>

@SdkInternalApi
public class UnknownContentLengthAsyncRequestBodySubscriber
extends Object
implements org.reactivestreams.Subscriber<CloseableAsyncRequestBody>

Method Summary

Modifier and Type	Method	Description
void	onComplete()
void	onError(Throwable t)
void	onNext(CloseableAsyncRequestBody asyncRequestBody)
void	onSubscribe(org.reactivestreams.Subscription s)

Methods inherited from class java.lang.Object

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

Method Detail

onSubscribe

public void onSubscribe(org.reactivestreams.Subscription s)

Specified by:

onSubscribe in interface org.reactivestreams.Subscriber<CloseableAsyncRequestBody>

onNext

public void onNext(CloseableAsyncRequestBody asyncRequestBody)

Specified by:

onNext in interface org.reactivestreams.Subscriber<CloseableAsyncRequestBody>

onError

public void onError(Throwable t)

Specified by:

onError in interface org.reactivestreams.Subscriber<CloseableAsyncRequestBody>

onComplete

public void onComplete()

Specified by:

onComplete in interface org.reactivestreams.Subscriber<CloseableAsyncRequestBody>