public static class Priority2StreamConverters.EnrichAnySteppableWithParStream<A,S extends java.util.stream.BaseStream<?,S>,CC> extends java.lang.Object implements MakesParallelStream<A,S>
Constructor and Description |
---|
EnrichAnySteppableWithParStream(CC cc,
scala.Function1<CC,MakesStepper<A,EfficientSubstep>> steppize,
StreamShape<A,S> ss) |
Modifier and Type | Method and Description |
---|---|
S |
parStream() |
public EnrichAnySteppableWithParStream(CC cc, scala.Function1<CC,MakesStepper<A,EfficientSubstep>> steppize, StreamShape<A,S> ss)