diff options
Diffstat (limited to 'flow-stream/src/main/scala/com/github/jodersky/flow/stream/impl/SerialConnectionLogic.scala')
| -rw-r--r-- | flow-stream/src/main/scala/com/github/jodersky/flow/stream/impl/SerialConnectionLogic.scala | 4 |
1 files changed, 3 insertions, 1 deletions
diff --git a/flow-stream/src/main/scala/com/github/jodersky/flow/stream/impl/SerialConnectionLogic.scala b/flow-stream/src/main/scala/com/github/jodersky/flow/stream/impl/SerialConnectionLogic.scala index 526ea40..8af106f 100644 --- a/flow-stream/src/main/scala/com/github/jodersky/flow/stream/impl/SerialConnectionLogic.scala +++ b/flow-stream/src/main/scala/com/github/jodersky/flow/stream/impl/SerialConnectionLogic.scala @@ -110,7 +110,9 @@ private[stream] class SerialConnectionLogic( connectionPromise.success(Serial.Connection(port, settings)) //complete materialized value stageActor unwatch manager stageActor watch operator - pull(in) // start pulling input + if (!isClosed(in)) { + pull(in) // start pulling input + } case other => val ex = new StreamSerialException(s"Stage actor received unknown message [$other]") |