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 void
onComplete()
void
onError(Throwable t)
void
onNext(ByteBuffer byteBuffer)
void
onSubscribe(org.reactivestreams.Subscription s)
-
-
-
Method Detail
-
onSubscribe
public void onSubscribe(org.reactivestreams.Subscription s)
- Specified by:
onSubscribe
in interfaceorg.reactivestreams.Subscriber<ByteBuffer>
-
onNext
public void onNext(ByteBuffer byteBuffer)
- Specified by:
onNext
in interfaceorg.reactivestreams.Subscriber<ByteBuffer>
-
onError
public void onError(Throwable t)
- Specified by:
onError
in interfaceorg.reactivestreams.Subscriber<ByteBuffer>
-
onComplete
public void onComplete()
- Specified by:
onComplete
in interfaceorg.reactivestreams.Subscriber<ByteBuffer>
-
-