diff options
| author | Jakob Odersky <jakob@odersky.com> | 2016-03-11 22:37:57 -0800 |
|---|---|---|
| committer | Jakob Odersky <jakob@odersky.com> | 2016-03-11 22:37:57 -0800 |
| commit | f514d9d013b8059adeb4e326845f0b2b5e93ab02 (patch) | |
| tree | 0f046791437f1c92df7ce3bb65f923286bf8be08 /flow-stream/src/main/scala/com/github/jodersky/flow/stream/impl/SerialConnectionStage.scala | |
| parent | 0d319d22fc77df39563b743829d969f161d40e53 (diff) | |
| download | akka-serial-f514d9d013b8059adeb4e326845f0b2b5e93ab02.tar.gz akka-serial-f514d9d013b8059adeb4e326845f0b2b5e93ab02.tar.bz2 akka-serial-f514d9d013b8059adeb4e326845f0b2b5e93ab02.zip | |
Clean up streaming code
Closes #30
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. |