public final < C > ParallelFlux < C > collect ( Supplier < ? extends C > collectionSupplier , BiConsumer < ? super C , ? super T > collector ) { return onAssembly ( new ParallelCollect <> ( 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 .