public final ParallelFlux<T> filter(Predicate<? super T> predicate){
  Objects.requireNonNull(predicate,"predicate");
  return onAssembly(new ParallelUnorderedFilter<>(this,predicate));
}

public final ParallelFlux < T > filter ( Predicate < ? super T > predicate ) { Objects . requireNonNull ( predicate , "predicate" ) ; return onAssembly ( new ParallelUnorderedFilter < > ( this , predicate ) ) ; }
filters the source values on each ' rail ' . < p > note that the same predicate may be called from multiple threads concurrently .
