add explicit reference to operator in open command

2 files changed, 2 insertions, 2 deletions

diff --git a/flow-main/src/main/scala/com/github/jodersky/flow/Serial.scala b/flow-main/src/main/scala/com/github/jodersky/flow/Serial.scala
index f8305c2..54fea6b 100644
--- a/flow-main/src/main/scala/com/github/jodersky/flow/Serial.scala
+++ b/flow-main/src/main/scala/com/github/jodersky/flow/Serial.scala
@@ -37,7 +37,7 @@ object Serial extends ExtensionKey[SerialExt] {
    * @param twoStopBits set to use two stop bits instead of one
    * @param parity type of parity to use with serial port
    */
-  case class Opened(port: String, baud: Int, characterSize: Int, twoStopBits: Boolean, parity: Parity.Parity) extends Event
+  case class Opened(port: String, baud: Int, characterSize: Int, twoStopBits: Boolean, parity: Parity.Parity, operator: ActorRef) extends Event
   
   
   case class Register(receiver: ActorRef) extends Command
diff --git a/flow-main/src/main/scala/com/github/jodersky/flow/SerialManager.scala b/flow-main/src/main/scala/com/github/jodersky/flow/SerialManager.scala
index ce75cc0..0d69213 100644
--- a/flow-main/src/main/scala/com/github/jodersky/flow/SerialManager.scala
+++ b/flow-main/src/main/scala/com/github/jodersky/flow/SerialManager.scala
@@ -36,7 +36,7 @@ class SerialManager extends Actor with ActorLogging {
       case Failure(t) => sender ! CommandFailed(c, t)
       case Success(serial) => {
         val operator = context.actorOf(Props(classOf[SerialOperator], serial), name = escapePortString(port))
-        val opened = Opened(serial.port, serial.baud, serial.characterSize, serial.twoStopBits, Parity(serial.parity))
+        val opened = Opened(serial.port, serial.baud, serial.characterSize, serial.twoStopBits, Parity(serial.parity), operator)
         sender.tell(opened, operator)
       }
     }