aboutsummaryrefslogtreecommitdiff
path: root/scala/src/main/scala/com/github/jodersky/ace/SafeSerial.scala
diff options
context:
space:
mode:
authorJakob Odersky <jodersky@gmail.com>2013-02-26 17:14:53 +0100
committerJakob Odersky <jodersky@gmail.com>2013-02-26 17:14:53 +0100
commit77db2136559ccef7d84cf6c0fd0166a970224680 (patch)
tree4addef09cfaa1567a952ed3b0522ecd26f96df75 /scala/src/main/scala/com/github/jodersky/ace/SafeSerial.scala
parent03edd62b745f225075fab0d96e0ec93f96c3466c (diff)
downloadace-77db2136559ccef7d84cf6c0fd0166a970224680.tar.gz
ace-77db2136559ccef7d84cf6c0fd0166a970224680.tar.bz2
ace-77db2136559ccef7d84cf6c0fd0166a970224680.zip
restructure scala directory in view of providing seperate projects for serial implementations
Diffstat (limited to 'scala/src/main/scala/com/github/jodersky/ace/SafeSerial.scala')
-rw-r--r--scala/src/main/scala/com/github/jodersky/ace/SafeSerial.scala35
1 files changed, 0 insertions, 35 deletions
diff --git a/scala/src/main/scala/com/github/jodersky/ace/SafeSerial.scala b/scala/src/main/scala/com/github/jodersky/ace/SafeSerial.scala
deleted file mode 100644
index d75d6f5..0000000
--- a/scala/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