Class 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 Detail

      • onSubscribe

        public void onSubscribe​(org.reactivestreams.Subscription s)
        Specified by:
        onSubscribe in interface org.reactivestreams.Subscriber<ByteBuffer>
      • onNext

        public void onNext​(ByteBuffer byteBuffer)
        Specified by:
        onNext in interface org.reactivestreams.Subscriber<ByteBuffer>
      • onError

        public void onError​(Throwable t)
        Specified by:
        onError in interface org.reactivestreams.Subscriber<ByteBuffer>
      • onComplete

        public void onComplete()
        Specified by:
        onComplete in interface org.reactivestreams.Subscriber<ByteBuffer>