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

=str #25091 javadsl ZipWithIndex to return java.lang.Long

Browse source
This commit is contained in:
Stefano Bonetti 2018-05-14 14:22:35 +01:00 • committed by Johan Andrén
parent 7591571372
commit db057df5d9
3 changed files with 6 additions and 6 deletions
Download patch file Download diff file Expand all files Collapse all files

4
akka-stream/src/main/scala/akka/stream/javadsl/Flow.scala
View file

@ -2476,8 +2476,8 @@ final class Flow[In, Out, Mat](delegate: scaladsl.Flow[In, Out, Mat]) extends Gr
*
* '''Cancels when''' downstream cancels
*/
def zipWithIndex: Flow[In, Pair[Out, Long], Mat] =
new Flow(delegate.zipWithIndex.map { case (elem, index) ⇒ Pair(elem, index) })
def zipWithIndex: Flow[In, Pair[Out, java.lang.Long], Mat] =
new Flow(delegate.zipWithIndex.map { case (elem, index) ⇒ Pair[Out, java.lang.Long](elem, index) })
/**
* If the first element has not passed through this stage before the provided timeout, the stream is failed

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

@ -1042,8 +1042,8 @@ final class Source[Out, Mat](delegate: scaladsl.Source[Out, Mat]) extends Graph[
*
* '''Cancels when''' downstream cancels
*/
def zipWithIndex: javadsl.Source[Pair[Out @uncheckedVariance, Long], Mat] =
new Source(delegate.zipWithIndex.map { case (elem, index) ⇒ Pair(elem, index) })
def zipWithIndex: javadsl.Source[Pair[Out @uncheckedVariance, java.lang.Long], Mat] =
new Source(delegate.zipWithIndex.map { case (elem, index) ⇒ Pair[Out, java.lang.Long](elem, index) })
/**
* Shortcut for running this `Source` with a foreach procedure. The given procedure is invoked

4
akka-stream/src/main/scala/akka/stream/javadsl/SubFlow.scala
View file

@ -1518,8 +1518,8 @@ class SubFlow[In, Out, Mat](delegate: scaladsl.SubFlow[Out, Mat, scaladsl.Flow[I
*
* '''Cancels when''' downstream cancels
*/
def zipWithIndex: SubFlow[In, akka.japi.Pair[Out @uncheckedVariance, Long], Mat] =
new SubFlow(delegate.zipWithIndex.map { case (elem, index) ⇒ akka.japi.Pair(elem, index) })
def zipWithIndex: SubFlow[In, akka.japi.Pair[Out @uncheckedVariance, java.lang.Long], Mat] =
new SubFlow(delegate.zipWithIndex.map { case (elem, index) ⇒ akka.japi.Pair[Out, java.lang.Long](elem, index) })
/**
* If the first element has not passed through this stage before the provided timeout, the stream is failed