From 12ecd4298939fdaac4d1daa5ba983b0580e901bf Mon Sep 17 00:00:00 2001 From: kerr Date: Tue, 6 Sep 2022 16:17:27 +0800 Subject: [PATCH] =str Make Source.range simpler. (#31551) --- akka-stream/src/main/scala/akka/stream/javadsl/Source.scala | 5 +---- 1 file changed, 1 insertion(+), 4 deletions(-) diff --git a/akka-stream/src/main/scala/akka/stream/javadsl/Source.scala b/akka-stream/src/main/scala/akka/stream/javadsl/Source.scala index 6d13086b30..1915da5f45 100755 --- a/akka-stream/src/main/scala/akka/stream/javadsl/Source.scala +++ b/akka-stream/src/main/scala/akka/stream/javadsl/Source.scala @@ -175,10 +175,7 @@ object Source { * @see [[scala.collection.immutable.Range.inclusive(Int, Int, Int)]] */ def range(start: Int, end: Int, step: Int): javadsl.Source[Integer, NotUsed] = - fromIterator[Integer](new function.Creator[util.Iterator[Integer]]() { - def create(): util.Iterator[Integer] = - Range.inclusive(start, end, step).iterator.asJava.asInstanceOf[util.Iterator[Integer]] - }) + new Source(scaladsl.Source(Range.inclusive(start, end, step).asInstanceOf[immutable.Iterable[Integer]])) /** * Start a new `Source` from the given `Future`. The stream will consist of