raboof/pekko
1
0
Fork 0
Code Issues Pull requests Projects Releases 6 Packages Wiki Activity Actions 10

!str remove now-unneeded imports

Browse source
This commit is contained in:
Roland Kuhn 2014-04-01 13:26:11 +02:00
parent 3cf21aced3
commit 7bcd71cd50
6 changed files with 0 additions and 15 deletions
Download patch file Download diff file Expand all files Collapse all files

2
akka-stream/src/test/scala/akka/stream/StreamConcatSpec.scala
View file

@ -4,12 +4,10 @@
package akka.stream
import akka.stream.impl.{ IteratorProducer, ActorBasedProcessorGenerator }
import akka.stream.Stream
import akka.stream.testkit.StreamTestKit
import akka.testkit.AkkaSpec
class StreamConcatSpec extends AkkaSpec {
import system.dispatcher
val gen = new ActorBasedProcessorGenerator(GeneratorSettings(
initialInputBufferSize = 2,

3
akka-stream/src/test/scala/akka/stream/StreamGroupBySpec.scala
View file

@ -8,13 +8,10 @@ import akka.stream.testkit._
import akka.testkit.AkkaSpec
import org.reactivestreams.api.Producer
import akka.stream.impl.{ IteratorProducer, ActorBasedProcessorGenerator }
import akka.stream.Stream
@org.junit.runner.RunWith(classOf[org.scalatest.junit.JUnitRunner])
class StreamGroupBySpec extends AkkaSpec {
import system.dispatcher
val gen = new ActorBasedProcessorGenerator(GeneratorSettings(
initialInputBufferSize = 2,
maximumInputBufferSize = 2,

3
akka-stream/src/test/scala/akka/stream/StreamMergeSpec.scala
View file

@ -8,12 +8,9 @@ import akka.stream.testkit.StreamTestKit
import akka.testkit.AkkaSpec
import org.reactivestreams.api.Producer
import akka.stream.impl.{ IteratorProducer, ActorBasedProcessorGenerator }
import akka.stream.{ Stream, GeneratorSettings }
class StreamMergeSpec extends AkkaSpec {
import system.dispatcher
val gen = new ActorBasedProcessorGenerator(GeneratorSettings(
initialInputBufferSize = 2,
maximumInputBufferSize = 2,

3
akka-stream/src/test/scala/akka/stream/StreamSplitWhenSpec.scala
View file

@ -8,13 +8,10 @@ import akka.stream.testkit.StreamTestKit
import akka.testkit.AkkaSpec
import org.reactivestreams.api.Producer
import akka.stream.impl.{ IteratorProducer, ActorBasedProcessorGenerator }
import akka.stream.{ Stream, GeneratorSettings }
@org.junit.runner.RunWith(classOf[org.scalatest.junit.JUnitRunner])
class StreamSplitWhenSpec extends AkkaSpec {
import system.dispatcher
val gen = new ActorBasedProcessorGenerator(GeneratorSettings(
initialInputBufferSize = 2,
maximumInputBufferSize = 2,

2
akka-stream/src/test/scala/akka/stream/StreamTransformRecoverSpec.scala
View file

@ -13,8 +13,6 @@ import scala.util.control.NoStackTrace
@org.junit.runner.RunWith(classOf[org.scalatest.junit.JUnitRunner])
class StreamTransformRecoverSpec extends AkkaSpec {
import system.dispatcher
val gen = ProcessorGenerator(GeneratorSettings(
initialInputBufferSize = 2,
maximumInputBufferSize = 2,

2
akka-stream/src/test/scala/akka/stream/StreamZipSpec.scala
View file

@ -4,12 +4,10 @@
package akka.stream
import akka.stream.impl.{ IteratorProducer, ActorBasedProcessorGenerator }
import akka.stream.Stream
import akka.stream.testkit.StreamTestKit
import akka.testkit.AkkaSpec
class StreamZipSpec extends AkkaSpec {
import system.dispatcher
val gen = new ActorBasedProcessorGenerator(GeneratorSettings(
initialInputBufferSize = 2,