Class ParallelCollector.ParallelCollectorSubscriber<T,​A,​R>

    • Constructor Detail

      • ParallelCollectorSubscriber

        ParallelCollectorSubscriber​(org.reactivestreams.Subscriber<? super R> subscriber,
                                    int n,
                                    java.util.stream.Collector<T,​A,​R> collector)
    • Method Detail

      • innerError

        void innerError​(java.lang.Throwable ex)
      • innerComplete

        void innerComplete​(A value,
                           java.util.function.BinaryOperator<A> combiner)