diff options
Diffstat (limited to 'flow-stream/src/main/scala/com/github/jodersky/flow/stream/impl/SerialConnectionStage.scala')
-rw-r--r-- | flow-stream/src/main/scala/com/github/jodersky/flow/stream/impl/SerialConnectionStage.scala | 11 |
1 files changed, 6 insertions, 5 deletions
diff --git a/flow-stream/src/main/scala/com/github/jodersky/flow/stream/impl/SerialConnectionStage.scala b/flow-stream/src/main/scala/com/github/jodersky/flow/stream/impl/SerialConnectionStage.scala index 2efe3e9..bff1d26 100644 --- a/flow-stream/src/main/scala/com/github/jodersky/flow/stream/impl/SerialConnectionStage.scala +++ b/flow-stream/src/main/scala/com/github/jodersky/flow/stream/impl/SerialConnectionStage.scala @@ -2,11 +2,12 @@ package com.github.jodersky.flow package stream package impl -import akka.actor._ -import akka.util._ -import akka.stream._ -import akka.stream.stage._ -import scala.concurrent._ +import scala.concurrent.{Future, Promise} + +import akka.actor.ActorRef +import akka.stream.{Attributes, FlowShape, Inlet, Outlet} +import akka.stream.stage.{GraphStageLogic, GraphStageWithMaterializedValue} +import akka.util.ByteString /** * Graph stage that establishes and thereby materializes a serial connection. |