@@ -272,7 +272,7 @@ trait StreamExtensions {
272
272
else if (info.companion == LongAccumulator ) stream.asInstanceOf [Stream [Long ]].collect(LongAccumulator .supplier, LongAccumulator .boxedAdder, LongAccumulator .merger).asInstanceOf [C1 ]
273
273
else if (info.companion == DoubleAccumulator ) stream.asInstanceOf [Stream [Double ]].collect(DoubleAccumulator .supplier, DoubleAccumulator .boxedAdder, DoubleAccumulator .merger).asInstanceOf [C1 ]
274
274
else if (stream.isParallel) anyAcc.to(factory)
275
- else factory.fromSpecific(stream.iterator.asScala.nn )
275
+ else factory.fromSpecific(stream.iterator.asScala)
276
276
}
277
277
278
278
/** Convert a generic Java Stream wrapping a primitive type to a corresponding primitive
@@ -304,7 +304,7 @@ trait StreamExtensions {
304
304
if (info.companion == AnyAccumulator ) stream.collect(AnyAccumulator .supplier[Int ], AnyAccumulator .unboxedIntAdder, AnyAccumulator .merger[Int ]).asInstanceOf [C1 ]
305
305
else if (info.companion == IntAccumulator ) intAcc.asInstanceOf [C1 ]
306
306
else if (stream.isParallel) intAcc.to(factory)
307
- else factory.fromSpecific(stream.iterator.asInstanceOf [java.util.Iterator [Int ]].asScala.nn )
307
+ else factory.fromSpecific(stream.iterator.asInstanceOf [java.util.Iterator [Int ]].asScala)
308
308
}
309
309
}
310
310
@@ -331,7 +331,7 @@ trait StreamExtensions {
331
331
if (info.companion == AnyAccumulator ) stream.collect(AnyAccumulator .supplier[Long ], AnyAccumulator .unboxedLongAdder, AnyAccumulator .merger[Long ]).asInstanceOf [C1 ]
332
332
else if (info.companion == LongAccumulator ) longAcc.asInstanceOf [C1 ]
333
333
else if (stream.isParallel) longAcc.to(factory)
334
- else factory.fromSpecific(stream.iterator.asInstanceOf [java.util.Iterator [Long ]].asScala.nn )
334
+ else factory.fromSpecific(stream.iterator.asInstanceOf [java.util.Iterator [Long ]].asScala)
335
335
}
336
336
}
337
337
@@ -358,7 +358,7 @@ trait StreamExtensions {
358
358
if (info.companion == AnyAccumulator ) stream.collect(AnyAccumulator .supplier[Double ], AnyAccumulator .unboxedDoubleAdder, AnyAccumulator .merger[Double ]).asInstanceOf [C1 ]
359
359
else if (info.companion == DoubleAccumulator ) doubleAcc.asInstanceOf [C1 ]
360
360
else if (stream.isParallel) doubleAcc.to(factory)
361
- else factory.fromSpecific(stream.iterator.asInstanceOf [java.util.Iterator [Double ]].asScala.nn )
361
+ else factory.fromSpecific(stream.iterator.asInstanceOf [java.util.Iterator [Double ]].asScala)
362
362
}
363
363
}
364
364
}
0 commit comments