src/main/java/io/reactivex/parallel/ParallelFlowable.java
@CheckReturnValue
    @NonNull
    public final <C> ParallelFlowable<C> collect(@NonNull Callable<? extends C> collectionSupplier, @NonNull BiConsumer<? super C, ? super T> collector) {
        ObjectHelper.requireNonNull(collectionSupplier, "collectionSupplier is null");
        ObjectHelper.requireNonNull(collector, "collector is null");
        return RxJavaPlugins.onAssembly(new ParallelCollect<T, C>(this, collectionSupplier, collector));
    }
@CheckReturnValue
    @NonNull
    public final <C> ParallelFlowable<C> collect(@NonNull Callable<? extends C> collectionSupplier, @NonNull BiConsumer<? super C, ? super T> collector) {
        ObjectHelper.requireNonNull(collectionSupplier, "collectionSupplier is null");
        ObjectHelper.requireNonNull(collector, "collector is null");
        return RxJavaPlugins.onAssembly(new ParallelCollect<T, C>(this, collectionSupplier, collector));
    }
@ CheckReturnValue @ NonNull public final < C > ParallelFlowable < C > collect ( @ NonNull Callable < ? extends C > collectionSupplier , @ NonNull BiConsumer < ? super C , ? super T > collector ) { ObjectHelper . requireNonNull ( collectionSupplier , "collectionSupplier is null" ) ; ObjectHelper . requireNonNull ( collector , "collector is null" ) ; return RxJavaPlugins . onAssembly ( new ParallelCollect < T , C > ( this , collectionSupplier , collector ) ) ; }
Collect the elements in each rail into a collection supplied via a collectionSupplier
and collected into with a collector action, emitting the collection at the end.

@param <C> the collection type
@param collectionSupplier the supplier of the collection in each rail
@param collector the collector, taking the per-rail collection and the current item
@return the new ParallelFlowable instance
Collect the elements in each rail into a collection supplied via a collectionSupplier and collected into with a collector action emitting the collection at the end .