From 7bcd71cd50badb74701efe4eea6f5aa5a5a7d786 Mon Sep 17 00:00:00 2001 From: Roland Kuhn Date: Tue, 1 Apr 2014 13:26:11 +0200 Subject: [PATCH] !str remove now-unneeded imports --- akka-stream/src/test/scala/akka/stream/StreamConcatSpec.scala | 2 -- akka-stream/src/test/scala/akka/stream/StreamGroupBySpec.scala | 3 --- akka-stream/src/test/scala/akka/stream/StreamMergeSpec.scala | 3 --- .../src/test/scala/akka/stream/StreamSplitWhenSpec.scala | 3 --- .../test/scala/akka/stream/StreamTransformRecoverSpec.scala | 2 -- akka-stream/src/test/scala/akka/stream/StreamZipSpec.scala | 2 -- 6 files changed, 15 deletions(-) diff --git a/akka-stream/src/test/scala/akka/stream/StreamConcatSpec.scala b/akka-stream/src/test/scala/akka/stream/StreamConcatSpec.scala index 87ae3d90fd..618b46ff6f 100644 --- a/akka-stream/src/test/scala/akka/stream/StreamConcatSpec.scala +++ b/akka-stream/src/test/scala/akka/stream/StreamConcatSpec.scala @@ -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, diff --git a/akka-stream/src/test/scala/akka/stream/StreamGroupBySpec.scala b/akka-stream/src/test/scala/akka/stream/StreamGroupBySpec.scala index 30f7b2d129..4dcd1a093b 100644 --- a/akka-stream/src/test/scala/akka/stream/StreamGroupBySpec.scala +++ b/akka-stream/src/test/scala/akka/stream/StreamGroupBySpec.scala @@ -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, diff --git a/akka-stream/src/test/scala/akka/stream/StreamMergeSpec.scala b/akka-stream/src/test/scala/akka/stream/StreamMergeSpec.scala index 3c603368a7..61ca547d46 100644 --- a/akka-stream/src/test/scala/akka/stream/StreamMergeSpec.scala +++ b/akka-stream/src/test/scala/akka/stream/StreamMergeSpec.scala @@ -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, diff --git a/akka-stream/src/test/scala/akka/stream/StreamSplitWhenSpec.scala b/akka-stream/src/test/scala/akka/stream/StreamSplitWhenSpec.scala index 30908c580c..f459731440 100644 --- a/akka-stream/src/test/scala/akka/stream/StreamSplitWhenSpec.scala +++ b/akka-stream/src/test/scala/akka/stream/StreamSplitWhenSpec.scala @@ -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, diff --git a/akka-stream/src/test/scala/akka/stream/StreamTransformRecoverSpec.scala b/akka-stream/src/test/scala/akka/stream/StreamTransformRecoverSpec.scala index a3847f5544..d8e9c10ef2 100644 --- a/akka-stream/src/test/scala/akka/stream/StreamTransformRecoverSpec.scala +++ b/akka-stream/src/test/scala/akka/stream/StreamTransformRecoverSpec.scala @@ -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, diff --git a/akka-stream/src/test/scala/akka/stream/StreamZipSpec.scala b/akka-stream/src/test/scala/akka/stream/StreamZipSpec.scala index b1caf9d183..9da57bd7c7 100644 --- a/akka-stream/src/test/scala/akka/stream/StreamZipSpec.scala +++ b/akka-stream/src/test/scala/akka/stream/StreamZipSpec.scala @@ -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,