com.ibm.cos.v2.services.s3.internal.multipart

Class KnownContentLengthAsyncRequestBodySubscriber

java.lang.Object

com.ibm.cos.v2.services.s3.internal.multipart.KnownContentLengthAsyncRequestBodySubscriber

All Implemented Interfaces:

org.reactivestreams.Subscriber<AsyncRequestBody>

public class KnownContentLengthAsyncRequestBodySubscriber
extends Object
implements org.reactivestreams.Subscriber<AsyncRequestBody>

Method Summary

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

Methods inherited from class java.lang.Object

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

Method Detail

pause

public S3ResumeToken pause()

onSubscribe

public void onSubscribe(org.reactivestreams.Subscription s)

Specified by:

onSubscribe in interface org.reactivestreams.Subscriber<AsyncRequestBody>

onNext

public void onNext(AsyncRequestBody asyncRequestBody)

Specified by:

onNext in interface org.reactivestreams.Subscriber<AsyncRequestBody>

onError

public void onError(Throwable t)

Specified by:

onError in interface org.reactivestreams.Subscriber<AsyncRequestBody>

onComplete

public void onComplete()

Specified by:

onComplete in interface org.reactivestreams.Subscriber<AsyncRequestBody>