Class OperatorBufferWithTime.InexactSubscriber

    • 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.
    • Method Detail

      • onError

        public void onError​(java.lang.Throwable e)
        Description copied from interface: Observer
        Notifies the Observer that the Observable has experienced an error condition.

        If the Observable calls this method, it will not thereafter call Observer.onNext(T) or Observer.onCompleted().

        Parameters:
        e - the exception encountered by the Observable
      • scheduleChunk

        void scheduleChunk()
      • startNewChunk

        void startNewChunk()
      • emitChunk

        void emitChunk​(java.util.List<T> chunkToEmit)