aboutsummaryrefslogtreecommitdiff
path: root/scala/ace/src/main/scala/com/github/jodersky/ace/SafeSerial.scala
diff options
context:
space:
mode:
authorJakob Odersky <jodersky@gmail.com>2013-02-26 18:22:53 +0100
committerJakob Odersky <jodersky@gmail.com>2013-02-26 18:25:07 +0100
commit20a2350f9b33a797763413509781d0686fc38fe5 (patch)
tree0ee6f84433d8eaec6f2e3a89bae026c095502b25 /scala/ace/src/main/scala/com/github/jodersky/ace/SafeSerial.scala
parent7923f67f3090cd5a8c7e8281f62b0beca0846bec (diff)
downloadace-20a2350f9b33a797763413509781d0686fc38fe5.tar.gz
ace-20a2350f9b33a797763413509781d0686fc38fe5.tar.bz2
ace-20a2350f9b33a797763413509781d0686fc38fe5.zip
simplify scala implementation
Diffstat (limited to 'scala/ace/src/main/scala/com/github/jodersky/ace/SafeSerial.scala')
-rw-r--r--scala/ace/src/main/scala/com/github/jodersky/ace/SafeSerial.scala35
1 files changed, 0 insertions, 35 deletions
diff --git a/scala/ace/src/main/scala/com/github/jodersky/ace/SafeSerial.scala b/scala/ace/src/main/scala/com/github/jodersky/ace/SafeSerial.scala
deleted file mode 100644
index d75d6f5..0000000
--- a/scala/ace/src/main/scala/com/github/jodersky/ace/SafeSerial.scala
+++ /dev/null
@@ -1,35 +0,0 @@
-package com.github.jodersky.ace
-
-import com.github.jodersky.ace.protocol._
-import jssc.SerialPort
-import scala.concurrent.ExecutionContext.Implicits.global
-import scala.util.Try
-
-class SafeSerial(port: SerialPort) { self =>
- val physical = new PhysicalLayer(port)
- val link = new LinkLayer
- val transport = new TransportLayer
-
- val application = new ReactiveLayer[Message, String] {
- def receive(message: Message) = Console.println(message.data.map(_.toChar).mkString(""))
- def write(s: String) = writeToLower(Message(s.map(_.toChar.toInt))).map(x => s)
- }
-
- def send(s: String) = application.write(s)
- def close() = Try(port.closePort())
-
- physical connect link connect transport connect application
- physical.begin()
-}
-
-object SafeSerial {
- def open(port: String, rate: Int) = Try {
- val serialPort = new SerialPort(port);
- serialPort.openPort()
- serialPort.setParams(rate,
- SerialPort.DATABITS_8,
- SerialPort.STOPBITS_1,
- SerialPort.PARITY_NONE)
- serialPort
- } map (port => new SafeSerial(port))
-} \ No newline at end of file