com.ibm.cos.v2.core.async

Class BlockingOutputStreamAsyncRequestBody

java.lang.Object

com.ibm.cos.v2.core.async.BlockingOutputStreamAsyncRequestBody

All Implemented Interfaces:

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

public final class BlockingOutputStreamAsyncRequestBody
extends Object
implements AsyncRequestBody

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

The caller is responsible for calling OutputStream.close() on the outputStream() when writing is complete.

See Also:

AsyncRequestBody.forBlockingOutputStream(Long)

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	BlockingOutputStreamAsyncRequestBody.Builder

Method Summary

Modifier and Type	Method and Description
static BlockingOutputStreamAsyncRequestBody.Builder	builder() Creates a default builder for BlockingOutputStreamAsyncRequestBody.
Optional<Long>	contentLength()
CancellableOutputStream	outputStream() Return an output stream to which blocking writes can be made to the downstream service.
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

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

contentType, 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

outputStream

public CancellableOutputStream outputStream()

Return an output stream to which blocking writes can be made to the downstream service.

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

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

builder

public static BlockingOutputStreamAsyncRequestBody.Builder builder()

Creates a default builder for BlockingOutputStreamAsyncRequestBody.

contentLength

public Optional<Long> contentLength()

Specified by:

contentLength in interface AsyncRequestBody

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>