Scala 3/scala.collection.convert/StreamExtensions/MapHasParKeyValueStream

MapHasParKeyValueStream

implicit class MapHasParKeyValueStream[K, V, CC <: ([X, Y] =>> MapOps[X, Y, [K, V] =>> Map[K, V], _])](cc: CC[K, V])
Source:
StreamExtensions.scala
class Object
trait Matchable
class Any

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