diff options
Diffstat (limited to 'samples/rwc/src/main/scala/com/github/jodersky')
-rw-r--r-- | samples/rwc/src/main/scala/com/github/jodersky/flow/example/Main.scala | 2 | ||||
-rw-r--r-- | samples/rwc/src/main/scala/com/github/jodersky/flow/example/SerialHandler.scala | 5 |
2 files changed, 5 insertions, 2 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 0a38618..71c40bc 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 @@ -32,7 +32,7 @@ object Main { val serial = system.actorOf(Props(classOf[SerialHandler], port, baud), name = "serial-handler") readLine() - serial ! ByteString(42) + serial ! ByteString("hello back".getBytes()) readLine() serial ! "close" diff --git a/samples/rwc/src/main/scala/com/github/jodersky/flow/example/SerialHandler.scala b/samples/rwc/src/main/scala/com/github/jodersky/flow/example/SerialHandler.scala index 2f7dfc3..8a717d1 100644 --- a/samples/rwc/src/main/scala/com/github/jodersky/flow/example/SerialHandler.scala +++ b/samples/rwc/src/main/scala/com/github/jodersky/flow/example/SerialHandler.scala @@ -26,7 +26,10 @@ class SerialHandler(port: String, baud: Int) extends Actor with ActorLogging { case Opened(operator) => println("Port opened.") context become { - case Received(data) => println("received data: " + formatData(data)) + case Received(data) => { + println("received data: " + formatData(data)) + println("as string: " + new String(data.toArray, "UTF-8")) + } case Wrote(data) => println("wrote ACK: " + formatData(data)) case CommandFailed(_, _) => println("write failed") case Closed => context stop self |