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

Modified iff statements from JavaDSL/Flow.scala (#25785)

Browse source
This commit is contained in:
Prasanna J 2018-10-12 13:37:30 +05:30 • committed by Johan Andrén
parent b0de255d27
commit 1e883ced45
1 changed files with 4 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

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

@ -1245,7 +1245,8 @@ final class Flow[In, Out, Mat](delegate: scaladsl.Flow[In, Out, Mat]) extends Gr
/**
* Terminate processing (and cancel the upstream publisher) after predicate
* returns false for the first time, including the first failed element iff inclusive is true
* returns false for the first time. When inclusive is `true`, include the element
* for which the predicate returned `false`.
* Due to input buffering some elements may have been requested from upstream publishers
* that will then not be processed downstream of this step.
*
@ -1268,7 +1269,8 @@ final class Flow[In, Out, Mat](delegate: scaladsl.Flow[In, Out, Mat]) extends Gr
/**
* Terminate processing (and cancel the upstream publisher) after predicate
* returns false for the first time, including the first failed element iff inclusive is true
* returns false for the first time. When inclusive is `true`, include the element
* for which the predicate returned `false`.
* Due to input buffering some elements may have been requested from upstream publishers
* that will then not be processed downstream of this step.
*