aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
-rw-r--r--scala/rxtx/src/test/scala/com/github/jodersky/ace/rxtx/test/Main.scala8
1 files changed, 5 insertions, 3 deletions
diff --git a/scala/rxtx/src/test/scala/com/github/jodersky/ace/rxtx/test/Main.scala b/scala/rxtx/src/test/scala/com/github/jodersky/ace/rxtx/test/Main.scala
index 1b42fa3..99981c0 100644
--- a/scala/rxtx/src/test/scala/com/github/jodersky/ace/rxtx/test/Main.scala
+++ b/scala/rxtx/src/test/scala/com/github/jodersky/ace/rxtx/test/Main.scala
@@ -10,7 +10,7 @@ import scala.concurrent.ExecutionContext.Implicits.global
object Main {
def main(args: Array[String]): Unit = {
- val serial = new Serial("/dev/ttyACM0")
+ val serial = new Serial("/dev/ttyACM0", 9600)
val framer = new Framer
val arq = new Arq(200)
val app = new SimpleActionLayer((s: Seq[Int]) => println(s))
@@ -18,10 +18,12 @@ object Main {
serial connect framer connect arq connect app
serial.begin()
+ print(">")
while (true) {
- app.send(Console.readLine.getBytes().map(_.toInt)).map(sent => Console.println("> " + sent))
+ val bytes = readLine.getBytes().map(_.toInt)
+ app.send(bytes).map(sent => "[sent] " + sent).recover{case ex => "[failed] " + ex}.map{s => println(s); print(">")}
}
}
-} \ No newline at end of file
+}