1 files changed, 0 insertions, 38 deletions
diff --git a/flow-stream/src/main/scala/ch/jodersky/flow/stream/impl/WatcherStage.scala b/flow-stream/src/main/scala/ch/jodersky/flow/stream/impl/WatcherStage.scala
deleted file mode 100644
index 82fad69..0000000
--- a/flow-stream/src/main/scala/ch/jodersky/flow/stream/impl/WatcherStage.scala
+++ /dev/null
@@ -1,38 +0,0 @@
-package ch.jodersky.flow
-package stream
-package impl
-
-import scala.concurrent.{Future, Promise}
-
-import akka.actor.ActorRef
-import akka.stream.{Attributes, Outlet, SourceShape}
-import akka.stream.stage.{GraphStageWithMaterializedValue, GraphStageLogic}
-
-
-private[stream] class WatcherStage(
-  ioManager: ActorRef,
-  ports: Set[String]
-) extends GraphStageWithMaterializedValue[SourceShape[String], Future[Serial.Watch]] {
-
-  val out = Outlet[String]("Watcher.out")
-
-  val shape = new SourceShape(out)
-
-  override def createLogicAndMaterializedValue(attributes: Attributes):
-      (GraphStageLogic, Future[Serial.Watch]) = {
-
-    val promise = Promise[Serial.Watch]
-
-    val logic = new WatcherLogic(
-      shape,
-      ioManager,
-      ports,
-      promise
-    )
-
-    (logic, promise.future)
-  }
-
-  override def toString = s"Watcher($ports)"
-
-}