Class ParallelReduceFull.ParallelReduceFullMainSubscriber<T>