diff options
| author | Jakob Odersky <jodersky@gmail.com> | 2013-06-19 17:06:30 +0200 |
|---|---|---|
| committer | Jakob Odersky <jodersky@gmail.com> | 2013-06-19 17:06:30 +0200 |
| commit | 9be0db6d86df1a56eca443ababba095d3aea688e (patch) | |
| tree | ed622e8c3f54b81b64171fe02808f9c55c027b5c | |
| parent | 86ae19a808e06a425df4b2b0f533b8693e0b933c (diff) | |
| download | akka-serial-9be0db6d86df1a56eca443ababba095d3aea688e.tar.gz akka-serial-9be0db6d86df1a56eca443ababba095d3aea688e.tar.bz2 akka-serial-9be0db6d86df1a56eca443ababba095d3aea688e.zip | |
give reader thread a nice name
| -rw-r--r-- | src/main/scala/com/github/jodersky/flow/SerialOperator.scala | 1 |
1 files changed, 1 insertions, 0 deletions
diff --git a/src/main/scala/com/github/jodersky/flow/SerialOperator.scala b/src/main/scala/com/github/jodersky/flow/SerialOperator.scala index 6177188..aa320e1 100644 --- a/src/main/scala/com/github/jodersky/flow/SerialOperator.scala +++ b/src/main/scala/com/github/jodersky/flow/SerialOperator.scala @@ -18,6 +18,7 @@ class SerialOperator(serial: LowSerial, handler: ActorRef) extends Actor { private var continueReading = true override def run() { + Thread.currentThread().setName("flow-reader" + serial.port) while (continueReading) { println("beginning read") val data = ByteString(serial.read()) |