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/Serial.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/Serial.scala')
| -rw-r--r-- | flow-stream/src/main/scala/com/github/jodersky/flow/stream/Serial.scala | 12 |
1 files changed, 5 insertions, 7 deletions
diff --git a/flow-stream/src/main/scala/com/github/jodersky/flow/stream/Serial.scala b/flow-stream/src/main/scala/com/github/jodersky/flow/stream/Serial.scala index 26efcc9..6d250df 100644 --- a/flow-stream/src/main/scala/com/github/jodersky/flow/stream/Serial.scala +++ b/flow-stream/src/main/scala/com/github/jodersky/flow/stream/Serial.scala @@ -1,16 +1,14 @@ package com.github.jodersky.flow package stream -import akka.actor._ +import scala.concurrent.Future + +import akka.actor.{Extension, ActorSystem, ExtendedActorSystem, ExtensionId, ExtensionIdProvider} +import akka.io.IO import akka.stream.scaladsl.Flow -import akka.stream._ -import akka.stream.stage._ -import akka.dispatch.ExecutionContexts import akka.util.ByteString -import com.github.jodersky.flow.{Serial => CoreSerial, _} -import scala.concurrent._ -import akka.io._ +import com.github.jodersky.flow.{Serial => CoreSerial} import impl._ object Serial extends ExtensionId[Serial] with ExtensionIdProvider { |