diff options
Diffstat (limited to 'flow-main/src/main/scala/com/github/jodersky/flow/SerialOperator.scala')
-rw-r--r-- | flow-main/src/main/scala/com/github/jodersky/flow/SerialOperator.scala | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/flow-main/src/main/scala/com/github/jodersky/flow/SerialOperator.scala b/flow-main/src/main/scala/com/github/jodersky/flow/SerialOperator.scala index 5524125..f40f4de 100644 --- a/flow-main/src/main/scala/com/github/jodersky/flow/SerialOperator.scala +++ b/flow-main/src/main/scala/com/github/jodersky/flow/SerialOperator.scala @@ -3,7 +3,7 @@ package com.github.jodersky.flow import java.nio.ByteBuffer import com.github.jodersky.flow.internal.Reader -import com.github.jodersky.flow.internal.ReaderDied +import com.github.jodersky.flow.internal.ThreadDied import com.github.jodersky.flow.internal.SerialConnection import Serial.Close @@ -57,7 +57,7 @@ class SerialOperator(connection: SerialConnection, bufferSize: Int, client: Acto } //go down with reader thread - case ReaderDied(ex) => throw ex + case ThreadDied(`reader`, ex) => throw ex } @@ -65,4 +65,4 @@ class SerialOperator(connection: SerialConnection, bufferSize: Int, client: Acto object SerialOperator { def apply(connection: SerialConnection, bufferSize: Int, client: ActorRef) = Props(classOf[SerialOperator], connection, bufferSize, client) -}
\ No newline at end of file +} |