diff options
author | Jakob Odersky <jakob@odersky.com> | 2016-05-16 15:28:59 -0700 |
---|---|---|
committer | Jakob Odersky <jakob@odersky.com> | 2016-06-09 03:30:35 -0700 |
commit | 92c4b3d41e06ad4b89004212c85248e9e6cd61d7 (patch) | |
tree | 69470f7c4ed48edaebea91964d7d552e7eaacf0d /flow-core/src/main/scala/com/github/jodersky/flow/internal/Reader.scala | |
parent | f6f26c2c9e3ec9bdd45fb384483b3450bef5984a (diff) | |
download | akka-serial-92c4b3d41e06ad4b89004212c85248e9e6cd61d7.tar.gz akka-serial-92c4b3d41e06ad4b89004212c85248e9e6cd61d7.tar.bz2 akka-serial-92c4b3d41e06ad4b89004212c85248e9e6cd61d7.zip |
Move project to `ch.jodersky` and upgrade sbt-jni
Diffstat (limited to 'flow-core/src/main/scala/com/github/jodersky/flow/internal/Reader.scala')
-rw-r--r-- | flow-core/src/main/scala/com/github/jodersky/flow/internal/Reader.scala | 36 |
1 files changed, 0 insertions, 36 deletions
diff --git a/flow-core/src/main/scala/com/github/jodersky/flow/internal/Reader.scala b/flow-core/src/main/scala/com/github/jodersky/flow/internal/Reader.scala deleted file mode 100644 index 59ad575..0000000 --- a/flow-core/src/main/scala/com/github/jodersky/flow/internal/Reader.scala +++ /dev/null @@ -1,36 +0,0 @@ -package com.github.jodersky.flow -package internal - -import akka.actor.{ Actor, ActorRef } -import akka.util.ByteString -import java.nio.ByteBuffer - -class Reader(serial: SerialConnection, buffer: ByteBuffer, operator: ActorRef, client: ActorRef) extends Thread { - def readLoop() = { - var stop = false - while (!serial.isClosed && !stop) { - try { - buffer.clear() - val length = serial.read(buffer) - buffer.limit(length) - val data = ByteString.fromByteBuffer(buffer) - client.tell(Serial.Received(data), operator) - } catch { - - //don't do anything if port is interrupted - case ex: PortInterruptedException => {} - - //stop and tell operator on other exception - case ex: Exception => { - stop = true - operator.tell(ThreadDied(this, ex), Actor.noSender) - } - } - } - } - - override def run() { - this.setName("flow-reader " + serial.port) - readLoop() - } -} |