Class PartSubscriber

  • All Implemented Interfaces:
    java.util.concurrent.Flow.Subscriber<java.nio.ByteBuffer>

    class PartSubscriber
    extends java.lang.Object
    implements java.util.concurrent.Flow.Subscriber<java.nio.ByteBuffer>
    • Field Detail

      • END_OF_PART

        static final java.nio.ByteBuffer END_OF_PART
      • part

        private final Part part
      • buffers

        private final java.util.concurrent.ConcurrentLinkedQueue<java.nio.ByteBuffer> buffers
      • upstream

        private final Upstream upstream
      • total

        private long total
    • Method Detail

      • onSubscribe

        public void onSubscribe​(java.util.concurrent.Flow.Subscription subscription)
        Specified by:
        onSubscribe in interface java.util.concurrent.Flow.Subscriber<java.nio.ByteBuffer>
      • onNext

        public void onNext​(java.nio.ByteBuffer item)
        Specified by:
        onNext in interface java.util.concurrent.Flow.Subscriber<java.nio.ByteBuffer>
      • onError

        public void onError​(java.lang.Throwable throwable)
        Specified by:
        onError in interface java.util.concurrent.Flow.Subscriber<java.nio.ByteBuffer>
      • onComplete

        public void onComplete()
        Specified by:
        onComplete in interface java.util.concurrent.Flow.Subscriber<java.nio.ByteBuffer>
      • abortUpstream

        void abortUpstream​(boolean cancel)
      • pollNext

        java.nio.ByteBuffer pollNext()
      • getPart

        public Part getPart()