1 files changed, 2 insertions, 2 deletions
diff --git a/flow-main/src/main/scala/com/github/jodersky/flow/internal/Reader.scala b/flow-main/src/main/scala/com/github/jodersky/flow/internal/Reader.scala
index 7b3f2ef..42400c8 100644
--- a/flow-main/src/main/scala/com/github/jodersky/flow/internal/Reader.scala
+++ b/flow-main/src/main/scala/com/github/jodersky/flow/internal/Reader.scala
@@ -27,7 +27,7 @@ class Reader(serial: SerialConnection, buffer: ByteBuffer, operator: ActorRef, c
         //stop and tell operator on other exception
         case ex: Exception => {
           stop = true
-          operator.tell(ReaderDied(ex), Actor.noSender)
+          operator.tell(ThreadDied(this, ex), Actor.noSender)
         }
       }
     }
@@ -37,4 +37,4 @@ class Reader(serial: SerialConnection, buffer: ByteBuffer, operator: ActorRef, c
     this.setName("flow-reader " + serial.port)
     readLoop()
   }
-}
-\ No newline at end of file
+}