From 0ce1ed2c67dc1db3feaa3e7bacd61e6fb1e11877 Mon Sep 17 00:00:00 2001 From: Konrad `ktoso` Malawski Date: Wed, 21 Dec 2016 17:57:44 +0100 Subject: [PATCH] =str fix typo in GraphStage port validations It should be can not `push` instead "pull" closed port --- akka-stream/src/main/scala/akka/stream/stage/GraphStage.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/akka-stream/src/main/scala/akka/stream/stage/GraphStage.scala b/akka-stream/src/main/scala/akka/stream/stage/GraphStage.scala index cf6868a645..2241506e31 100644 --- a/akka-stream/src/main/scala/akka/stream/stage/GraphStage.scala +++ b/akka-stream/src/main/scala/akka/stream/stage/GraphStage.scala @@ -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 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") // No error, just InClosed caused the actual pull to be ignored, but the status flag still needs to be flipped