From b138668dd763573cd7d1015efde12e2547aa45f4 Mon Sep 17 00:00:00 2001 From: Konrad Malawski Date: Wed, 7 Jan 2015 11:02:41 +0100 Subject: [PATCH] =str #16385 update reactive streams to RC1, enable fixed TCK tests --- .../akka/stream/tck/AkkaIdentityProcessorVerification.scala | 5 ----- .../scala/akka/stream/tck/AkkaPublisherVerification.scala | 2 -- 2 files changed, 7 deletions(-) diff --git a/akka-stream-tck/src/test/scala/akka/stream/tck/AkkaIdentityProcessorVerification.scala b/akka-stream-tck/src/test/scala/akka/stream/tck/AkkaIdentityProcessorVerification.scala index 84447c5874..b06288e53f 100644 --- a/akka-stream-tck/src/test/scala/akka/stream/tck/AkkaIdentityProcessorVerification.scala +++ b/akka-stream-tck/src/test/scala/akka/stream/tck/AkkaIdentityProcessorVerification.scala @@ -37,11 +37,6 @@ abstract class AkkaIdentityProcessorVerification[T](val system: ActorSystem, env this(false) } - override def skipStochasticTests() = true // TODO maybe enable? - - // TODO re-enable this test once 1.0.0.RC1 is released, with https://github.com/reactive-streams/reactive-streams/pull/154 - override def spec317_mustSignalOnErrorWhenPendingAboveLongMaxValue() = notVerified("TODO Enable this test once https://github.com/reactive-streams/reactive-streams/pull/154 is merged (ETA 1.0.0.RC1)") - override def createErrorStatePublisher(): Publisher[T] = StreamTestKit.errorPublisher(new Exception("Unable to serve subscribers right now!")) diff --git a/akka-stream-tck/src/test/scala/akka/stream/tck/AkkaPublisherVerification.scala b/akka-stream-tck/src/test/scala/akka/stream/tck/AkkaPublisherVerification.scala index a35f490d6c..17b38b2f9b 100644 --- a/akka-stream-tck/src/test/scala/akka/stream/tck/AkkaPublisherVerification.scala +++ b/akka-stream-tck/src/test/scala/akka/stream/tck/AkkaPublisherVerification.scala @@ -35,8 +35,6 @@ abstract class AkkaPublisherVerification[T](val system: ActorSystem, env: TestEn implicit val materializer = FlowMaterializer(MaterializerSettings(system).copy(maxInputBufferSize = 512))(system) - override def skipStochasticTests() = true // TODO maybe enable? - @AfterClass def shutdownActorSystem(): Unit = { system.shutdown()