com.ibm.cos.v2.core.async

Class BlockingInputStreamAsyncRequestBody

java.lang.Object

com.ibm.cos.v2.core.async.BlockingInputStreamAsyncRequestBody

All Implemented Interfaces:

AsyncRequestBody, SdkPublisher<ByteBuffer>, org.reactivestreams.Publisher<ByteBuffer>

public final class BlockingInputStreamAsyncRequestBody
extends Object
implements AsyncRequestBody

An implementation of AsyncRequestBody that allows performing a blocking write of an input stream to a downstream service.

See AsyncRequestBody.forBlockingInputStream(Long).

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	BlockingInputStreamAsyncRequestBody.Builder

Method Summary

Modifier and Type	Method and Description
static BlockingInputStreamAsyncRequestBody.Builder	builder() Creates a default builder for BlockingInputStreamAsyncRequestBody.
void	cancel() Cancel any running write (and mark the stream as failed).
Optional<Long>	contentLength()
String	contentType()
void	subscribe(org.reactivestreams.Subscriber<? super ByteBuffer> s)
long	writeInputStream(InputStream inputStream) Block the calling thread and write the provided input stream to the downstream service.

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.ibm.cos.v2.core.async.AsyncRequestBody

empty, forBlockingInputStream, forBlockingOutputStream, fromByteBuffer, fromByteBuffers, fromByteBuffersUnsafe, fromByteBufferUnsafe, fromBytes, fromBytesUnsafe, fromFile, fromFile, fromFile, fromFile, fromInputStream, fromInputStream, fromInputStream, fromPublisher, fromRemainingByteBuffer, fromRemainingByteBuffers, fromRemainingByteBuffersUnsafe, fromRemainingByteBufferUnsafe, fromString, fromString, split, split

Methods inherited from interface com.ibm.cos.v2.core.async.SdkPublisher

adapt, addTrailingData, buffer, doAfterOnCancel, doAfterOnComplete, doAfterOnError, filter, filter, flatMapIterable, fromIterable, limit, map, subscribe

Method Detail

builder

public static BlockingInputStreamAsyncRequestBody.Builder builder()

Creates a default builder for BlockingInputStreamAsyncRequestBody.

contentLength

public Optional<Long> contentLength()

Specified by:

contentLength in interface AsyncRequestBody

Returns:

The content length of the data being produced.

contentType

public String contentType()

Specified by:

contentType in interface AsyncRequestBody

Returns:

The content type of the data being produced.

writeInputStream

public long writeInputStream(InputStream inputStream)

Block the calling thread and write the provided input stream to the downstream service.

This method will block the calling thread immediately. This means that this request body should usually be passed to the SDK before this method is called.

This method will return the amount of data written when the entire input stream has been written. This will throw an exception if writing the input stream has failed.

You can invoke cancel() to cancel any blocked write calls to the downstream service (and mark the stream as failed).

cancel

public void cancel()

Cancel any running write (and mark the stream as failed).

subscribe

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

Specified by:

subscribe in interface org.reactivestreams.Publisher<ByteBuffer>