=str don't run streams test twice because of junit.RunWith annotation
This commit is contained in:
parent
03aeb667e1
commit
c6267fdc37
22 changed files with 0 additions and 22 deletions
|
|
@ -8,7 +8,6 @@ import java.lang.reflect.Modifier
|
|||
import org.scalatest.Matchers
|
||||
import org.scalatest.WordSpec
|
||||
|
||||
@org.junit.runner.RunWith(classOf[org.scalatest.junit.JUnitRunner])
|
||||
class DslConsistencySpec extends WordSpec with Matchers {
|
||||
|
||||
val sFlowClass = classOf[akka.stream.scaladsl.Flow[_, _]]
|
||||
|
|
|
|||
|
|
@ -8,7 +8,6 @@ import java.lang.reflect.Method
|
|||
import org.scalatest.Matchers
|
||||
import org.scalatest.WordSpec
|
||||
|
||||
@org.junit.runner.RunWith(classOf[org.scalatest.junit.JUnitRunner])
|
||||
class DslFactoriesConsistencySpec extends WordSpec with Matchers {
|
||||
|
||||
// configuration //
|
||||
|
|
|
|||
|
|
@ -101,7 +101,6 @@ object ActorPublisherSpec {
|
|||
|
||||
}
|
||||
|
||||
@org.junit.runner.RunWith(classOf[org.scalatest.junit.JUnitRunner])
|
||||
class ActorPublisherSpec extends AkkaSpec with ImplicitSender {
|
||||
import akka.stream.actor.ActorPublisherSpec._
|
||||
|
||||
|
|
|
|||
|
|
@ -91,7 +91,6 @@ object ActorSubscriberSpec {
|
|||
}
|
||||
}
|
||||
|
||||
@org.junit.runner.RunWith(classOf[org.scalatest.junit.JUnitRunner])
|
||||
class ActorSubscriberSpec extends AkkaSpec with ImplicitSender {
|
||||
import ActorSubscriberMessage._
|
||||
import ActorSubscriberSpec._
|
||||
|
|
|
|||
|
|
@ -10,7 +10,6 @@ import akka.stream.testkit.StreamTestKit
|
|||
import akka.testkit.TestProbe
|
||||
import org.reactivestreams.{ Subscriber, Subscription }
|
||||
|
||||
@org.junit.runner.RunWith(classOf[org.scalatest.junit.JUnitRunner])
|
||||
class SynchronousPublisherFromIterableSpec extends AkkaSpec {
|
||||
|
||||
"A SynchronousPublisherFromIterable" must {
|
||||
|
|
|
|||
|
|
@ -7,7 +7,6 @@ import akka.testkit.TestProbe
|
|||
import akka.stream.testkit.AkkaSpec
|
||||
import akka.stream.FlowMaterializer
|
||||
|
||||
@org.junit.runner.RunWith(classOf[org.scalatest.junit.JUnitRunner])
|
||||
class FlowDispatcherSpec extends AkkaSpec {
|
||||
|
||||
implicit val materializer = FlowMaterializer()
|
||||
|
|
|
|||
|
|
@ -9,7 +9,6 @@ import akka.stream.FlowMaterializer
|
|||
import akka.stream.testkit.AkkaSpec
|
||||
import akka.stream.testkit.StreamTestKit
|
||||
|
||||
@org.junit.runner.RunWith(classOf[org.scalatest.junit.JUnitRunner])
|
||||
class FlowDropWithinSpec extends AkkaSpec {
|
||||
|
||||
implicit val materializer = FlowMaterializer()
|
||||
|
|
|
|||
|
|
@ -11,7 +11,6 @@ import akka.stream.MaterializerSettings
|
|||
import akka.stream.testkit._
|
||||
import org.reactivestreams.Publisher
|
||||
|
||||
@org.junit.runner.RunWith(classOf[org.scalatest.junit.JUnitRunner])
|
||||
class FlowGroupBySpec extends AkkaSpec {
|
||||
|
||||
val settings = MaterializerSettings(system)
|
||||
|
|
|
|||
|
|
@ -13,7 +13,6 @@ import akka.stream.testkit.AkkaSpec
|
|||
import akka.stream.testkit.ScriptedTest
|
||||
import akka.stream.testkit.StreamTestKit
|
||||
|
||||
@org.junit.runner.RunWith(classOf[org.scalatest.junit.JUnitRunner])
|
||||
class FlowGroupedWithinSpec extends AkkaSpec with ScriptedTest {
|
||||
|
||||
val settings = MaterializerSettings(system)
|
||||
|
|
|
|||
|
|
@ -11,7 +11,6 @@ import akka.stream.MaterializerSettings
|
|||
import akka.stream.testkit.{ AkkaSpec, StreamTestKit }
|
||||
import akka.stream.testkit.StreamTestKit.{ OnComplete, OnError, OnNext }
|
||||
|
||||
@org.junit.runner.RunWith(classOf[org.scalatest.junit.JUnitRunner])
|
||||
class FlowIterableSpec extends AkkaSpec {
|
||||
|
||||
val settings = MaterializerSettings(system)
|
||||
|
|
|
|||
|
|
@ -13,7 +13,6 @@ import akka.stream.testkit.StreamTestKit.OnComplete
|
|||
import akka.stream.testkit.StreamTestKit.OnError
|
||||
import akka.stream.testkit.StreamTestKit.OnNext
|
||||
|
||||
@org.junit.runner.RunWith(classOf[org.scalatest.junit.JUnitRunner])
|
||||
class FlowIteratorSpec extends AkkaSpec {
|
||||
|
||||
val settings = MaterializerSettings(system)
|
||||
|
|
|
|||
|
|
@ -15,7 +15,6 @@ import akka.stream.testkit.StreamTestKit
|
|||
import akka.testkit.TestLatch
|
||||
import akka.testkit.TestProbe
|
||||
|
||||
@org.junit.runner.RunWith(classOf[org.scalatest.junit.JUnitRunner])
|
||||
class FlowMapAsyncSpec extends AkkaSpec {
|
||||
|
||||
implicit val materializer = FlowMaterializer()
|
||||
|
|
|
|||
|
|
@ -14,7 +14,6 @@ import akka.stream.testkit.AkkaSpec
|
|||
import akka.stream.testkit.ScriptedTest
|
||||
import akka.testkit.TestProbe
|
||||
|
||||
@org.junit.runner.RunWith(classOf[org.scalatest.junit.JUnitRunner])
|
||||
class FlowOnCompleteSpec extends AkkaSpec with ScriptedTest {
|
||||
|
||||
val settings = MaterializerSettings(system)
|
||||
|
|
|
|||
|
|
@ -72,7 +72,6 @@ object FlowSpec {
|
|||
}
|
||||
}
|
||||
|
||||
@org.junit.runner.RunWith(classOf[org.scalatest.junit.JUnitRunner])
|
||||
class FlowSpec extends AkkaSpec(ConfigFactory.parseString("akka.actor.debug.receive=off\nakka.loglevel=INFO")) {
|
||||
import FlowSpec._
|
||||
|
||||
|
|
|
|||
|
|
@ -11,7 +11,6 @@ import akka.stream.testkit.AkkaSpec
|
|||
import akka.stream.testkit.StreamTestKit
|
||||
import org.reactivestreams.Publisher
|
||||
|
||||
@org.junit.runner.RunWith(classOf[org.scalatest.junit.JUnitRunner])
|
||||
class FlowSplitWhenSpec extends AkkaSpec {
|
||||
|
||||
val settings = MaterializerSettings(system)
|
||||
|
|
|
|||
|
|
@ -9,7 +9,6 @@ import akka.stream.FlowMaterializer
|
|||
import akka.stream.testkit.AkkaSpec
|
||||
import akka.stream.testkit.StreamTestKit
|
||||
|
||||
@org.junit.runner.RunWith(classOf[org.scalatest.junit.JUnitRunner])
|
||||
class FlowTakeWithinSpec extends AkkaSpec {
|
||||
|
||||
implicit val materializer = FlowMaterializer()
|
||||
|
|
|
|||
|
|
@ -11,7 +11,6 @@ import akka.stream.TimerTransformer
|
|||
|
||||
import akka.stream.testkit.{ AkkaSpec, StreamTestKit }
|
||||
|
||||
@org.junit.runner.RunWith(classOf[org.scalatest.junit.JUnitRunner])
|
||||
class FlowTimerTransformerSpec extends AkkaSpec {
|
||||
|
||||
implicit val materializer = FlowMaterializer()
|
||||
|
|
|
|||
|
|
@ -30,7 +30,6 @@ object FlowTransformRecoverSpec {
|
|||
}
|
||||
}
|
||||
|
||||
@org.junit.runner.RunWith(classOf[org.scalatest.junit.JUnitRunner])
|
||||
class FlowTransformRecoverSpec extends AkkaSpec {
|
||||
import FlowTransformRecoverSpec._
|
||||
|
||||
|
|
|
|||
|
|
@ -14,7 +14,6 @@ import akka.stream.testkit.{ AkkaSpec, StreamTestKit }
|
|||
import akka.testkit.{ EventFilter, TestProbe }
|
||||
import com.typesafe.config.ConfigFactory
|
||||
|
||||
@org.junit.runner.RunWith(classOf[org.scalatest.junit.JUnitRunner])
|
||||
class FlowTransformSpec extends AkkaSpec(ConfigFactory.parseString("akka.actor.debug.receive=off\nakka.loglevel=INFO")) {
|
||||
|
||||
val settings = MaterializerSettings(system)
|
||||
|
|
|
|||
|
|
@ -27,7 +27,6 @@ object ImplicitFlowMaterializerSpec {
|
|||
}
|
||||
}
|
||||
|
||||
@org.junit.runner.RunWith(classOf[org.scalatest.junit.JUnitRunner])
|
||||
class ImplicitFlowMaterializerSpec extends AkkaSpec with ImplicitSender {
|
||||
import ImplicitFlowMaterializerSpec._
|
||||
|
||||
|
|
|
|||
|
|
@ -10,7 +10,6 @@ import akka.stream.FlowMaterializer
|
|||
import akka.stream.testkit.AkkaSpec
|
||||
import akka.stream.testkit.StreamTestKit
|
||||
|
||||
@org.junit.runner.RunWith(classOf[org.scalatest.junit.JUnitRunner])
|
||||
class TickSourceSpec extends AkkaSpec {
|
||||
|
||||
implicit val materializer = FlowMaterializer()
|
||||
|
|
|
|||
|
|
@ -76,7 +76,6 @@ object TimerTransformerSpec {
|
|||
}
|
||||
}
|
||||
|
||||
@org.junit.runner.RunWith(classOf[org.scalatest.junit.JUnitRunner])
|
||||
class TimerTransformerSpec extends AkkaSpec {
|
||||
import TimerTransformerSpec._
|
||||
|
||||
|
|
|
|||
Loading…
Add table
Add a link
Reference in a new issue