com.ibm.cos.v2.core.internal.http.async

Class SimpleHttpContentPublisher

java.lang.Object

com.ibm.cos.v2.core.internal.http.async.SimpleHttpContentPublisher

All Implemented Interfaces:

SdkHttpContentPublisher, org.reactivestreams.Publisher<ByteBuffer>

public final class SimpleHttpContentPublisher
extends Object
implements SdkHttpContentPublisher

Implementation of SdkHttpContentPublisher that provides all it's data at once. Useful for non streaming operations that are already marshalled into memory.

Constructor Summary

Constructors

Constructor and Description
SimpleHttpContentPublisher(SdkHttpFullRequest request)

Method Summary

Modifier and Type	Method and Description
Optional<Long>	contentLength()
void	subscribe(org.reactivestreams.Subscriber<? super ByteBuffer> s)

Methods inherited from class java.lang.Object

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

Constructor Detail

SimpleHttpContentPublisher

public SimpleHttpContentPublisher(SdkHttpFullRequest request)

Method Detail

contentLength

public Optional<Long> contentLength()

Specified by:

contentLength in interface SdkHttpContentPublisher

Returns:

The content length of the data being produced.

subscribe

public void subscribe(org.reactivestreams.Subscriber<? super ByteBuffer> s)

Specified by:

subscribe in interface org.reactivestreams.Publisher<ByteBuffer>