@@ -208,25 +208,25 @@ extends Priority1StreamConverters
208
208
with converterImpl.Priority1StepConverters
209
209
with converterImpl.Priority1AccumulatorConverters
210
210
{
211
- implicit class EnrichDoubleArrayWithStream (a : Array [Double ])
212
- extends MakesSequentialStream [java.lang.Double , DoubleStream ] with MakesParallelStream [java.lang.Double , DoubleStream ] {
211
+ implicit final class EnrichDoubleArrayWithStream (private val a : Array [Double ])
212
+ extends AnyVal with MakesSequentialStream [java.lang.Double , DoubleStream ] with MakesParallelStream [java.lang.Double , DoubleStream ] {
213
213
def seqStream : DoubleStream = java.util.Arrays .stream(a)
214
214
def parStream : DoubleStream = seqStream.parallel
215
215
}
216
216
217
- implicit class EnrichIntArrayWithStream (a : Array [Int ])
218
- extends MakesSequentialStream [java.lang.Integer , IntStream ] with MakesParallelStream [java.lang.Integer , IntStream ] {
217
+ implicit final class EnrichIntArrayWithStream (private val a : Array [Int ])
218
+ extends AnyVal with MakesSequentialStream [java.lang.Integer , IntStream ] with MakesParallelStream [java.lang.Integer , IntStream ] {
219
219
def seqStream : IntStream = java.util.Arrays .stream(a)
220
220
def parStream : IntStream = seqStream.parallel
221
221
}
222
222
223
- implicit class EnrichLongArrayWithStream (a : Array [Long ])
224
- extends MakesSequentialStream [java.lang.Long , LongStream ] with MakesParallelStream [java.lang.Long , LongStream ] {
223
+ implicit final class EnrichLongArrayWithStream (private val a : Array [Long ])
224
+ extends AnyVal with MakesSequentialStream [java.lang.Long , LongStream ] with MakesParallelStream [java.lang.Long , LongStream ] {
225
225
def seqStream : LongStream = java.util.Arrays .stream(a)
226
226
def parStream : LongStream = seqStream.parallel
227
227
}
228
228
229
- implicit val primitiveAccumulateDoubleStream = new PrimitiveStreamAccumulator [Stream [Double ], DoubleAccumulator ] {
229
+ implicit val primitiveAccumulateDoubleStream = new PrimitiveStreamAccumulator [Stream [Double ], DoubleAccumulator ] {
230
230
def streamAccumulate (stream : Stream [Double ]): DoubleAccumulator =
231
231
stream.collect(DoubleAccumulator .supplier, DoubleAccumulator .boxedAdder, DoubleAccumulator .merger)
232
232
}
@@ -274,7 +274,7 @@ with converterImpl.Priority1AccumulatorConverters
274
274
implicit val primitiveUnboxLongStream2 =
275
275
primitiveUnboxLongStream.asInstanceOf [PrimitiveStreamUnboxer [java.lang.Long , LongStream ]]
276
276
277
- implicit class RichDoubleStream (stream : DoubleStream ) {
277
+ implicit final class RichDoubleStream (private val stream : DoubleStream ) extends AnyVal {
278
278
def accumulate = stream.collect(DoubleAccumulator .supplier, DoubleAccumulator .adder, DoubleAccumulator .merger)
279
279
280
280
def toScala [Coll [_]](implicit cbf : collection.generic.CanBuildFrom [Nothing , Double , Coll [Double ]]): Coll [Double ] = {
@@ -287,7 +287,7 @@ with converterImpl.Priority1AccumulatorConverters
287
287
}
288
288
}
289
289
290
- implicit class RichIntStream (stream : IntStream ) {
290
+ implicit final class RichIntStream (private val stream : IntStream ) extends AnyVal {
291
291
def accumulate = stream.collect(IntAccumulator .supplier, IntAccumulator .adder, IntAccumulator .merger)
292
292
293
293
def toScala [Coll [_]](implicit cbf : collection.generic.CanBuildFrom [Nothing , Int , Coll [Int ]]): Coll [Int ] = {
@@ -300,7 +300,7 @@ with converterImpl.Priority1AccumulatorConverters
300
300
}
301
301
}
302
302
303
- implicit class RichLongStream (stream : LongStream ) {
303
+ implicit final class RichLongStream (private val stream : LongStream ) extends AnyVal {
304
304
def accumulate = stream.collect(LongAccumulator .supplier, LongAccumulator .adder, LongAccumulator .merger)
305
305
306
306
def toScala [Coll [_]](implicit cbf : collection.generic.CanBuildFrom [Nothing , Long , Coll [Long ]]): Coll [Long ] = {
0 commit comments