From 20a2350f9b33a797763413509781d0686fc38fe5 Mon Sep 17 00:00:00 2001 From: Jakob Odersky Date: Tue, 26 Feb 2013 18:22:53 +0100 Subject: simplify scala implementation --- .../scala/com/github/jodersky/ace/SafeSerial.scala | 35 ---------------------- 1 file changed, 35 deletions(-) delete mode 100644 scala/ace/src/main/scala/com/github/jodersky/ace/SafeSerial.scala (limited to 'scala/ace/src/main/scala/com/github/jodersky/ace/SafeSerial.scala') 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 -- cgit v1.2.3