aboutsummaryrefslogtreecommitdiff
path: root/flow-main/src/main/scala/com/github/jodersky/flow/SerialOperator.scala
diff options
context:
space:
mode:
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.scala6
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
+}