Class FlowableDoOnEach.DoOnEachSubscriber<T>

    • Field Detail

      • onError

        final Consumer<? super java.lang.Throwable> onError
      • onComplete

        final Action onComplete
      • onAfterTerminate

        final Action onAfterTerminate
    • Constructor Detail

      • DoOnEachSubscriber

        DoOnEachSubscriber​(org.reactivestreams.Subscriber<? super T> actual,
                           Consumer<? super T> onNext,
                           Consumer<? super java.lang.Throwable> onError,
                           Action onComplete,
                           Action onAfterTerminate)
    • Method Detail

      • onNext

        public void onNext​(T t)
      • onError

        public void onError​(java.lang.Throwable t)
        Specified by:
        onError in interface org.reactivestreams.Subscriber<T>
        Overrides:
        onError in class BasicFuseableSubscriber<T,​T>
      • poll

        @Nullable
        public T poll()
               throws java.lang.Throwable
        Description copied from interface: SimpleQueue
        Tries to dequeue a value (non-null) or returns null if the queue is empty.

        If the producer uses SimpleQueue.offer(Object, Object) and when polling in pairs, if the first poll() returns a non-null item, the second poll() is guaranteed to return a non-null item as well.

        Returns:
        the item or null to indicate an empty queue
        Throws:
        java.lang.Throwable - if some pre-processing of the dequeued item (usually through fused functions) throws.