diff options
Diffstat (limited to 'samples/rwc/src/main/scala/com/github/jodersky/flow/example/Main.scala')
-rw-r--r-- | samples/rwc/src/main/scala/com/github/jodersky/flow/example/Main.scala | 19 |
1 files changed, 7 insertions, 12 deletions
diff --git a/samples/rwc/src/main/scala/com/github/jodersky/flow/example/Main.scala b/samples/rwc/src/main/scala/com/github/jodersky/flow/example/Main.scala index 985513b..518efc2 100644 --- a/samples/rwc/src/main/scala/com/github/jodersky/flow/example/Main.scala +++ b/samples/rwc/src/main/scala/com/github/jodersky/flow/example/Main.scala @@ -1,20 +1,15 @@ package com.github.jodersky.flow package example -import scala.concurrent.ExecutionContext.Implicits.global -import scala.util.Success -import scala.util.Try -import com.github.jodersky.flow.Serial -import com.github.jodersky.flow.Serial._ import akka.actor.ActorSystem import akka.actor.Props -import akka.io.IO +import akka.actor.actorRef2Scala import akka.util.ByteString -import com.github.jodersky.flow.internal.InternalSerial object Main { def main(args: Array[String]): Unit = { + /*val isInt = Try(args(1).toInt) match { case Success(_) => true; case _ => false } if (!(args.length == 2 && isInt)) { println("invalid parameters") @@ -25,18 +20,18 @@ object Main { val port = "/dev/ttyACM0" val baud = 115200 - // InternalSerial.debug(true) - + // InternalSerial.debug(true) + implicit val system = ActorSystem("flow") val serial = system.actorOf(Props(classOf[SerialHandler], port, baud), name = "serial-handler") - + readLine() serial ! ByteString("hello back".getBytes()) - + readLine() serial ! "close" readLine() - + system.shutdown() } }
\ No newline at end of file |