MapHasParKeyValueStream
class MapHasParKeyValueStream[K, V, CC <: ([X, Y] =>> MapOps[X, Y, [K, V] =>> Map[K, V], _])](cc: CC[K, V])
- Source
- StreamExtensions.scala
Value members
Concrete methods
def asJavaParKeyStream[S <: BaseStream[_, _], St <: Stepper[_]](implicit s: StreamShape[K, S, St], st: StepperShape[K, St], @implicitNotFound("parKeyStream can only be called on maps where `keyStepper` returns a `Stepper with EfficientSplit`") isEfficient: CC[K, V] <:< MapOps[K, V, Map, _] { def keyStepper[S <: Stepper[_]](shape: StepperShape[K, S]): S & EfficientSplit; ; }): S
Create a parallel Java Stream for the keys of this map.
Create a parallel Java Stream for the keys of this map. If
the keys are primitive values, a corresponding specialized Stream is returned (e.g.,
IntStream).
- Source
- StreamExtensions.scala
def asJavaParStream[S <: BaseStream[_, _], St <: Stepper[_]](implicit s: StreamShape[(K, V), S, St], st: StepperShape[(K, V), St], @implicitNotFound("parStream can only be called on maps where `stepper` returns a `Stepper with EfficientSplit`") isEfficient: CC[K, V] <:< MapOps[K, V, Map, _] { def stepper[S <: Stepper[_]](shape: StepperShape[(K, V), S]): S & EfficientSplit; ; }): S
Create a parallel Java Stream for the (key, value) pairs of
this map.
Create a parallel Java Stream for the (key, value) pairs of
this map.
- Source
- StreamExtensions.scala
def asJavaParValueStream[S <: BaseStream[_, _], St <: Stepper[_]](implicit s: StreamShape[V, S, St], st: StepperShape[V, St], @implicitNotFound("parValueStream can only be called on maps where `valueStepper` returns a `Stepper with EfficientSplit`") isEfficient: CC[K, V] <:< MapOps[K, V, Map, _] { def valueStepper[S <: Stepper[_]](shape: StepperShape[V, S]): S & EfficientSplit; ; }): S
Create a parallel Java Stream for the values of this map.
Create a parallel Java Stream for the values of this map. If
the values are primitives, a corresponding specialized Stream is returned (e.g.,
IntStream).
- Source
- StreamExtensions.scala