Class OperatorBufferWithStartEndObservable.BufferingSubscriber

    • Field Detail

      • child

        final Subscriber<? super java.util.List<T>> child
      • chunks

        final java.util.List<java.util.List<T>> chunks
        Guarded by this.
      • done

        boolean done
        Guarded by this.
    • Constructor Detail

      • BufferingSubscriber

        public BufferingSubscriber​(Subscriber<? super java.util.List<T>> child)