remove rwc sample

3 files changed, 0 insertions, 93 deletions

diff --git a/flow-samples/rwc/README b/flow-samples/rwc/README
deleted file mode 100644
index 843e38d..0000000
--- a/flow-samples/rwc/README
+++ /dev/null
@@ -1 +0,0 @@
-This sample tests a read(loop)-write-close procedure.
diff --git a/flow-samples/rwc/src/main/scala/com/github/jodersky/flow/example/Main.scala b/flow-samples/rwc/src/main/scala/com/github/jodersky/flow/example/Main.scala
deleted file mode 100644
index 518efc2..0000000
--- a/flow-samples/rwc/src/main/scala/com/github/jodersky/flow/example/Main.scala
+++ /dev/null
@@ -1,37 +0,0 @@
-package com.github.jodersky.flow
-package example
-
-import akka.actor.ActorSystem
-import akka.actor.Props
-import akka.actor.actorRef2Scala
-import akka.util.ByteString
-
-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")
-      println("parameters: port baud")
-      println("example: /dev/ttyACM0 115200")
-      return
-    }*/
-    val port = "/dev/ttyACM0"
-    val baud = 115200
-
-    // 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
diff --git a/flow-samples/rwc/src/main/scala/com/github/jodersky/flow/example/SerialHandler.scala b/flow-samples/rwc/src/main/scala/com/github/jodersky/flow/example/SerialHandler.scala
deleted file mode 100644
index 4b38c09..0000000
--- a/flow-samples/rwc/src/main/scala/com/github/jodersky/flow/example/SerialHandler.scala
+++ /dev/null
@@ -1,55 +0,0 @@
-package com.github.jodersky.flow.example
-
-import com.github.jodersky.flow.Serial._
-import akka.actor.Actor
-import akka.actor.ActorLogging
-import akka.actor.ActorRef
-import akka.util.ByteString
-import akka.io.IO
-import com.github.jodersky.flow.Serial
-import akka.actor.Terminated
-
-class SerialHandler(port: String, baud: Int) extends Actor with ActorLogging {
-  import context._
-
-  log.info(s"Requesting manager to open port: ${port}, baud: ${baud}")
-  IO(Serial) ! Serial.Open(self, port, baud)
-
-  def receive = {
-
-    case OpenFailed(reason, _, _, _, _, _) => {
-      log.error(s"Connection failed, stopping handler. Reason: ${reason}")
-      context stop self
-    }
-
-    case Opened(port, _, _, _, _) => {
-      log.info(s"Port ${port} is now open.")
-      context become opened(sender)
-    }
-  }
-
-  def opened(operator: ActorRef): Receive = {
-   
-    case Received(data) => {
-      log.info("Received data: " + formatData(data))
-      log.info("As string: " + new String(data.toArray, "UTF-8"))
-    }
-    case Wrote(data) => log.info("Got ACK for writing data: " + formatData(data))
-    case Closed(None) => {
-      log.info("Operator closed normally, exiting handler.")
-      context stop self
-    }
-    case Closed(Some(ex)) => {
-      log.info("Operator crashed, exiting handler.")
-      context stop self
-    }
-    case "close" => {
-      log.info("Initiating close.")
-      operator ! Close
-    }
-    case data: ByteString => operator ! Write(data, true)
-  }
-
-  private def formatData(data: ByteString) = data.mkString("[", ",", "]")
-
-}
\ No newline at end of file