aboutsummaryrefslogtreecommitdiff
path: root/flow-core/src/test/scala/ch/jodersky/flow/SerialOperatorSpec.scala
diff options
context:
space:
mode:
authorJakob Odersky <jakob@odersky.com>2017-01-08 21:16:25 +0100
committerJakob Odersky <jakob@odersky.com>2017-01-21 17:22:10 -0800
commit23959966760174477a6b0fcbf9dd1e8ef37c643b (patch)
tree9a0ee44eb43a8c13af57b0d06313f3aabf9e4555 /flow-core/src/test/scala/ch/jodersky/flow/SerialOperatorSpec.scala
parent6c371ba6d69c891c1f0d6df00bb643e1d543cc9d (diff)
downloadakka-serial-23959966760174477a6b0fcbf9dd1e8ef37c643b.tar.gz
akka-serial-23959966760174477a6b0fcbf9dd1e8ef37c643b.tar.bz2
akka-serial-23959966760174477a6b0fcbf9dd1e8ef37c643b.zip
Rename project to akka-serial
Diffstat (limited to 'flow-core/src/test/scala/ch/jodersky/flow/SerialOperatorSpec.scala')
-rw-r--r--flow-core/src/test/scala/ch/jodersky/flow/SerialOperatorSpec.scala49
1 files changed, 0 insertions, 49 deletions
diff --git a/flow-core/src/test/scala/ch/jodersky/flow/SerialOperatorSpec.scala b/flow-core/src/test/scala/ch/jodersky/flow/SerialOperatorSpec.scala
deleted file mode 100644
index 4c1dd94..0000000
--- a/flow-core/src/test/scala/ch/jodersky/flow/SerialOperatorSpec.scala
+++ /dev/null
@@ -1,49 +0,0 @@
-package ch.jodersky.flow
-
-import scala.concurrent.duration._
-
-import akka.actor.{ActorRef, ActorSystem}
-import akka.testkit.{ImplicitSender, TestKit}
-import akka.util.ByteString
-import org.scalatest._
-
-case class Ack(n: Int) extends Serial.Event
-
-class SerialOperatorSpec
- extends TestKit(ActorSystem("serial-operator"))
- with ImplicitSender
- with WordSpecLike
- with Matchers
- with BeforeAndAfterAll
- with SequentialNestedSuiteExecution
- with PseudoTerminal {
-
- override def afterAll {
- TestKit.shutdownActorSystem(system)
- }
-
- def withEchoOp[A](action: ActorRef => A): A = {
- withEcho { case (port, settings) =>
- val connection = SerialConnection.open(port, settings)
- val operator = system.actorOf(SerialOperator.apply(connection, 1024, testActor))
- action(operator)
- }
- }
-
- "Serial operator" should {
-
- "follow the correct protocol" in withEchoOp { op =>
- expectMsgType[Serial.Opened]
-
- val data = ByteString("hello world".getBytes("utf-8"))
- op ! Serial.Write(data)
- expectMsg(Serial.Received(data))
-
- op ! Serial.Close
- expectMsg(Serial.Closed)
-
- }
-
- }
-
-}