aboutsummaryrefslogtreecommitdiff
path: root/flow-samples/watcher
diff options
context:
space:
mode:
authorJakob Odersky <jakob@odersky.com>2017-01-08 21:16:25 +0100
committerJakob Odersky <jakob@odersky.com>2017-01-21 17:22:10 -0800
commit23959966760174477a6b0fcbf9dd1e8ef37c643b (patch)
tree9a0ee44eb43a8c13af57b0d06313f3aabf9e4555 /flow-samples/watcher
parent6c371ba6d69c891c1f0d6df00bb643e1d543cc9d (diff)
downloadakka-serial-23959966760174477a6b0fcbf9dd1e8ef37c643b.tar.gz
akka-serial-23959966760174477a6b0fcbf9dd1e8ef37c643b.tar.bz2
akka-serial-23959966760174477a6b0fcbf9dd1e8ef37c643b.zip
Rename project to akka-serial
Diffstat (limited to 'flow-samples/watcher')
-rw-r--r--flow-samples/watcher/src/main/scala/ch/jodersky/flow/samples/watcher/main.scala50
1 files changed, 0 insertions, 50 deletions
diff --git a/flow-samples/watcher/src/main/scala/ch/jodersky/flow/samples/watcher/main.scala b/flow-samples/watcher/src/main/scala/ch/jodersky/flow/samples/watcher/main.scala
deleted file mode 100644
index 650d08e..0000000
--- a/flow-samples/watcher/src/main/scala/ch/jodersky/flow/samples/watcher/main.scala
+++ /dev/null
@@ -1,50 +0,0 @@
-package ch.jodersky.flow
-package samples.watcher
-
-import akka.actor.{ Actor, ActorLogging, ActorSystem, Props }
-import akka.io.IO
-import scala.io.StdIn
-
-class Watcher extends Actor with ActorLogging {
- import context._
-
- val ports = List(
- "/dev/ttyUSB\\d+",
- "/dev/ttyACM\\d+",
- "/dev/cu\\d+",
- "/dev/ttyS\\d+"
- )
-
- override def preStart() = {
- val cmd = Serial.Watch()
- IO(Serial) ! cmd //watch for new devices
- log.info(s"Watching ${cmd.directory} for new devices.")
- }
-
- def receive = {
-
- case Serial.CommandFailed(w: Serial.Watch, err) =>
- log.error(err, s"Could not get a watch on ${w.directory}.")
- context stop self
-
- case Serial.Connected(path) =>
- log.info(s"New device: ${path}")
- ports.find(path matches _) match {
- case Some(port) => log.info(s"Device is a serial device.")
- case None => log.warning(s"Device is NOT serial device.")
- }
-
- }
-
-}
-
-object Main {
-
- def main(args: Array[String]): Unit = {
- val system = ActorSystem("flow")
- val watcher = system.actorOf(Props(classOf[Watcher]), name = "watcher")
- StdIn.readLine()
- system.terminate()
- }
-
-}