aboutsummaryrefslogtreecommitdiff
path: root/flow-stream/src/main/scala/ch/jodersky/flow/stream/impl/SerialConnectionStage.scala
diff options
context:
space:
mode:
authorJakob Odersky <jakob@odersky.com>2016-05-16 15:28:59 -0700
committerJakob Odersky <jakob@odersky.com>2016-06-09 03:30:35 -0700
commit92c4b3d41e06ad4b89004212c85248e9e6cd61d7 (patch)
tree69470f7c4ed48edaebea91964d7d552e7eaacf0d /flow-stream/src/main/scala/ch/jodersky/flow/stream/impl/SerialConnectionStage.scala
parentf6f26c2c9e3ec9bdd45fb384483b3450bef5984a (diff)
downloadakka-serial-92c4b3d41e06ad4b89004212c85248e9e6cd61d7.tar.gz
akka-serial-92c4b3d41e06ad4b89004212c85248e9e6cd61d7.tar.bz2
akka-serial-92c4b3d41e06ad4b89004212c85248e9e6cd61d7.zip
Move project to `ch.jodersky` and upgrade sbt-jni
Diffstat (limited to 'flow-stream/src/main/scala/ch/jodersky/flow/stream/impl/SerialConnectionStage.scala')
-rw-r--r--flow-stream/src/main/scala/ch/jodersky/flow/stream/impl/SerialConnectionStage.scala49
1 files changed, 49 insertions, 0 deletions
diff --git a/flow-stream/src/main/scala/ch/jodersky/flow/stream/impl/SerialConnectionStage.scala b/flow-stream/src/main/scala/ch/jodersky/flow/stream/impl/SerialConnectionStage.scala
new file mode 100644
index 0000000..ceeac01
--- /dev/null
+++ b/flow-stream/src/main/scala/ch/jodersky/flow/stream/impl/SerialConnectionStage.scala
@@ -0,0 +1,49 @@
+package ch.jodersky.flow
+package stream
+package impl
+
+import scala.concurrent.{Future, Promise}
+
+import akka.actor.ActorRef
+import akka.stream.{Attributes, FlowShape, Inlet, Outlet}
+import akka.stream.stage.{GraphStageLogic, GraphStageWithMaterializedValue}
+import akka.util.ByteString
+
+/**
+ * Graph stage that establishes and thereby materializes a serial connection.
+ * The actual connection logic is deferred to [[SerialConnectionLogic]].
+ */
+private[stream] class SerialConnectionStage(
+ manager: ActorRef,
+ port: String,
+ settings: SerialSettings,
+ failOnOverflow: Boolean,
+ bufferSize: Int
+) extends GraphStageWithMaterializedValue[FlowShape[ByteString, ByteString], Future[Serial.Connection]] {
+
+ val in: Inlet[ByteString] = Inlet("Serial.in")
+ val out: Outlet[ByteString] = Outlet("Serial.out")
+
+ val shape: FlowShape[ByteString, ByteString] = FlowShape(in, out)
+
+ override def createLogicAndMaterializedValue(inheritedAttributes: Attributes):
+ (GraphStageLogic, Future[Serial.Connection]) = {
+
+ val connectionPromise = Promise[Serial.Connection]
+
+ val logic = new SerialConnectionLogic(
+ shape,
+ manager,
+ port,
+ settings,
+ failOnOverflow,
+ bufferSize,
+ connectionPromise
+ )
+
+ (logic, connectionPromise.future)
+ }
+
+ override def toString = s"Serial($port)"
+
+}