Package software.amazon.encryption.s3.internal

Class CipherAsyncRequestBody

java.lang.Object

software.amazon.encryption.s3.internal.CipherAsyncRequestBody

All Implemented Interfaces:

org.reactivestreams.Publisher<ByteBuffer>, software.amazon.awssdk.core.async.AsyncRequestBody, software.amazon.awssdk.core.async.SdkPublisher<ByteBuffer>

public class CipherAsyncRequestBody
extends Object
implements software.amazon.awssdk.core.async.AsyncRequestBody

An AsyncRequestBody which encrypts and decrypts data as it passes through using a configured Cipher instance.

Constructor Summary

Constructors

Constructor	Description
CipherAsyncRequestBody(software.amazon.awssdk.core.async.AsyncRequestBody wrappedAsyncRequestBody, Long ciphertextLength, CryptographicMaterials materials, byte[] iv)
CipherAsyncRequestBody(software.amazon.awssdk.core.async.AsyncRequestBody wrappedAsyncRequestBody, Long ciphertextLength, CryptographicMaterials materials, byte[] iv, boolean isLastPart)

Method Summary

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

Methods inherited from class java.lang.Object

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

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

contentType, split, split

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

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

Constructor Detail

CipherAsyncRequestBody

public CipherAsyncRequestBody(software.amazon.awssdk.core.async.AsyncRequestBody wrappedAsyncRequestBody,
                              Long ciphertextLength,
                              CryptographicMaterials materials,
                              byte[] iv,
                              boolean isLastPart)

CipherAsyncRequestBody

public CipherAsyncRequestBody(software.amazon.awssdk.core.async.AsyncRequestBody wrappedAsyncRequestBody,
                              Long ciphertextLength,
                              CryptographicMaterials materials,
                              byte[] iv)

Method Detail

subscribe

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

Specified by:

subscribe in interface org.reactivestreams.Publisher<ByteBuffer>

contentLength

public Optional<Long> contentLength()

Specified by:

contentLength in interface software.amazon.awssdk.core.async.AsyncRequestBody