1 files changed, 5 insertions, 9 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 42400c8..59ad575 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
@@ -1,13 +1,9 @@
-package com.github.jodersky.flow.internal
+package com.github.jodersky.flow
+package internal
 
-import java.nio.ByteBuffer
-
-import com.github.jodersky.flow.PortInterruptedException
-import com.github.jodersky.flow.Serial.Received
-
-import akka.actor.Actor
-import akka.actor.ActorRef
+import akka.actor.{ Actor, ActorRef }
 import akka.util.ByteString
+import java.nio.ByteBuffer
 
 class Reader(serial: SerialConnection, buffer: ByteBuffer, operator: ActorRef, client: ActorRef) extends Thread {
   def readLoop() = {
@@ -18,7 +14,7 @@ class Reader(serial: SerialConnection, buffer: ByteBuffer, operator: ActorRef, c
         val length = serial.read(buffer)
         buffer.limit(length)
         val data = ByteString.fromByteBuffer(buffer)
-        client.tell(Received(data), operator)
+        client.tell(Serial.Received(data), operator)
       } catch {
 
         //don't do anything if port is interrupted