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

Merge pull request #22056 from akka/ktoso-typo-1

Browse source 
=str fix typo in GraphStage port validations
This commit is contained in:
Konrad `ktoso` Malawski 2016-12-22 13:42:40 +01:00 • committed by GitHub
commit b1e146c836
1 changed files with 1 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files

2
akka-stream/src/main/scala/akka/stream/stage/GraphStage.scala
View file

@ -455,7 +455,7 @@ abstract class GraphStageLogic private[stream] (val inCount: Int, val outCount:
// Detailed error information should not add overhead to the hot path // Detailed error information should not add overhead to the hot path
ReactiveStreamsCompliance.requireNonNullElement(elem) ReactiveStreamsCompliance.requireNonNullElement(elem)
require(!isClosed(out), s"Cannot pull closed port ($out)") require(!isClosed(out), s"Cannot push closed port ($out)")
require(isAvailable(out), s"Cannot push port ($out) twice") require(isAvailable(out), s"Cannot push port ($out) twice")
// No error, just InClosed caused the actual pull to be ignored, but the status flag still needs to be flipped // No error, just InClosed caused the actual pull to be ignored, but the status flag still needs to be flipped