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

eliminate extraneous takeWhile method

Browse source
This commit is contained in:
László van den Hoek 2018-05-30 16:05:01 +02:00
parent a14347e18d
commit e12a492679
2 changed files with 3 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files

2
akka-stream/src/main/mima-filters/2.5.13.backwards.excludes Normal file
View file

@ -0,0 +1,2 @@
# #25175 eliminate extraneous takeWhile$default$2 method in Java DSL
ProblemFilters.exclude[DirectMissingMethodProblem]("akka.stream.javadsl.Flow.takeWhile$default$2")

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

@ -1256,7 +1256,7 @@ final class Flow[In, Out, Mat](delegate: scaladsl.Flow[In, Out, Mat]) extends Gr
*
* See also [[Flow.limit]], [[Flow.limitWeighted]]
*/
def takeWhile(p: function.Predicate[Out], inclusive: Boolean = false): javadsl.Flow[In, Out, Mat] = new Flow(delegate.takeWhile(p.test, inclusive))
def takeWhile(p: function.Predicate[Out], inclusive: Boolean): javadsl.Flow[In, Out, Mat] = new Flow(delegate.takeWhile(p.test, inclusive))
/**
* Terminate processing (and cancel the upstream publisher) after predicate