raboof/pekko
1
0
Fork 0
Code Issues Pull requests Projects Releases 6 Packages Wiki Activity Actions 10

+str #18807 Source.range for Java DSL

Browse source
This commit is contained in:
Alexander Golubev 2015-12-04 09:46:50 -05:00
parent 89d32f6f09
commit 357af9c388
1 changed files with 4 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files

5
akka-stream/src/main/scala/akka/stream/javadsl/Source.scala
View file

@ -18,6 +18,7 @@ import org.reactivestreams.{ Publisher, Subscriber }
import scala.annotation.unchecked.uncheckedVariance
import scala.collection.JavaConverters._
import scala.collection.immutable
import scala.collection.immutable.Range.Inclusive
import scala.concurrent.duration.FiniteDuration
import scala.concurrent.{ Future, Promise }
import scala.language.{ higherKinds, implicitConversions }
@ -132,7 +133,9 @@ object Source {
def range(start: Int, end: Int, step: Int): javadsl.Source[Integer, Unit] =
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 Inclusive(start, end, step) {
override def toString: String = s"Range($start to $end, step = $step)"
}.iterator.asJava.asInstanceOf[util.Iterator[Integer]]
})
/**