Class BufferedCipherSubscriber
- java.lang.Object
-
- software.amazon.encryption.s3.internal.BufferedCipherSubscriber
-
- All Implemented Interfaces:
org.reactivestreams.Subscriber<ByteBuffer>
public class BufferedCipherSubscriber extends Object implements org.reactivestreams.Subscriber<ByteBuffer>
A subscriber which decrypts data by buffering the object's contents so that authentication can be done before any plaintext is released. This prevents "release of unauthenticated plaintext" at the cost of allocating a large buffer.
-
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description voidonComplete()voidonError(Throwable t)voidonNext(ByteBuffer byteBuffer)voidonSubscribe(org.reactivestreams.Subscription s)
-
-
-
Method Detail
-
onSubscribe
public void onSubscribe(org.reactivestreams.Subscription s)
- Specified by:
onSubscribein interfaceorg.reactivestreams.Subscriber<ByteBuffer>
-
onNext
public void onNext(ByteBuffer byteBuffer)
- Specified by:
onNextin interfaceorg.reactivestreams.Subscriber<ByteBuffer>
-
onError
public void onError(Throwable t)
- Specified by:
onErrorin interfaceorg.reactivestreams.Subscriber<ByteBuffer>
-
onComplete
public void onComplete()
- Specified by:
onCompletein interfaceorg.reactivestreams.Subscriber<ByteBuffer>
-
-