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

=str #16385 update reactive streams to RC1, enable fixed TCK tests

Browse source
This commit is contained in:
Konrad Malawski 2015-01-07 11:02:41 +01:00
parent 0f1feac42e
commit b138668dd7
2 changed files with 0 additions and 7 deletions
Download patch file Download diff file Expand all files Collapse all files

5
akka-stream-tck/src/test/scala/akka/stream/tck/AkkaIdentityProcessorVerification.scala
View file

@ -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!"))

2
akka-stream-tck/src/test/scala/akka/stream/tck/AkkaPublisherVerification.scala
View file

@ -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()