software.amazon.awssdk.core.internal.async

Class ByteArrayAsyncRequestBody

java.lang.Object

software.amazon.awssdk.core.internal.async.ByteArrayAsyncRequestBody

All Implemented Interfaces:

org.reactivestreams.Publisher<ByteBuffer>, AsyncRequestBody

public final class ByteArrayAsyncRequestBody
extends Object
implements AsyncRequestBody

An implementation of AsyncRequestBody for providing data from memory. This is created using static methods on AsyncRequestBody

See Also:

AsyncRequestBody.fromBytes(byte[]), AsyncRequestBody.fromByteBuffer(ByteBuffer), AsyncRequestBody.fromString(String)

Constructor Summary

Constructors

Constructor and Description
ByteArrayAsyncRequestBody(byte[] bytes)

Method Summary

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

Methods inherited from class java.lang.Object

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

Methods inherited from interface software.amazon.awssdk.core.async.AsyncRequestBody

empty, fromByteBuffer, fromBytes, fromFile, fromFile, fromString, fromString

Constructor Detail

ByteArrayAsyncRequestBody

public ByteArrayAsyncRequestBody(byte[] bytes)

Method Detail

contentLength

public 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>