escalate exception in case watcher crashes

1 files changed, 2 insertions, 1 deletions

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 686cdb3..d163b0a 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
@@ -1,7 +1,7 @@
 package com.github.jodersky.flow
 
 import akka.actor.{ Actor, ActorLogging, OneForOneStrategy }
-import akka.actor.SupervisorStrategy.Stop
+import akka.actor.SupervisorStrategy.{ Escalate, Stop }
 import internal.{ SerialConnection, Watcher }
 import scala.util.{ Failure, Success, Try }
 
@@ -15,6 +15,7 @@ class SerialManager extends Actor with ActorLogging {
   import context._
 
   override val supervisorStrategy = OneForOneStrategy() {
+    case _: Exception if sender == watcher => Escalate
     case _: Exception => Stop
   }