Class ParallelFilterTry.BaseFilterSubscriber<T>

    • Field Detail

      • upstream

        org.reactivestreams.Subscription upstream
      • done

        boolean done
    • Method Detail

      • request

        public final void request​(long n)
        Specified by:
        request in interface org.reactivestreams.Subscription
      • cancel

        public final void cancel()
        Specified by:
        cancel in interface org.reactivestreams.Subscription
      • onNext

        public final void onNext​(T t)
        Specified by:
        onNext in interface org.reactivestreams.Subscriber<T>