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

Merge pull request #17116 from ktoso/wip-reactive-streams-rc4-ktoso

Browse source 
=str #17109 update reactive streams to RC4
This commit is contained in:
Konrad Malawski 2015-04-01 12:06:18 +02:00
commit ee32c5bc42
6 changed files with 2 additions and 11 deletions
Download patch file Download diff file Expand all files Collapse all files

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

@ -25,7 +25,7 @@ abstract class AkkaIdentityProcessorVerification[T](env: TestEnvironment, publis
def this() = this(false)
override def createErrorStatePublisher(): Publisher[T] =
override def createFailedPublisher(): Publisher[T] =
StreamTestKit.errorPublisher(new Exception("Unable to serve subscribers right now!"))
def processorFromFlow(flow: Flow[T, T, _])(implicit mat: ActorFlowMaterializer): Processor[T, T] = {

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

@ -29,7 +29,7 @@ abstract class AkkaPublisherVerification[T](val env: TestEnvironment, publisherS
implicit lazy val materializer = ActorFlowMaterializer(ActorFlowMaterializerSettings(system).copy(maxInputBufferSize = 512))(system)
override def createErrorStatePublisher(): Publisher[T] =
override def createFailedPublisher(): Publisher[T] =
StreamTestKit.errorPublisher(new Exception("Unable to serve subscribers right now!"))
def iterable(elements: Long): immutable.Iterable[Int] =

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

@ -13,6 +13,4 @@ class ConcatTest extends AkkaPublisherVerification[Int] {
Source(iterable(elements / 2)).concat(Source(iterable((elements + 1) / 2))).runWith(Sink.publisher)
}
// FIXME verifyNoAsyncErrors() without delay is wrong in TCK, enable again in RC4
override def optional_spec111_maySupportMultiSubscribe(): Unit = ()
}

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

@ -16,6 +16,4 @@ class FlattenTest extends AkkaPublisherVerification[Int] {
Source(List(s1, s2)).flatten(FlattenStrategy.concat).runWith(Sink.publisher)
}
// FIXME verifyNoAsyncErrors() without delay is wrong in TCK, enable again in RC4
override def optional_spec111_maySupportMultiSubscribe(): Unit = ()
}

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

@ -23,6 +23,4 @@ class GroupByTest extends AkkaPublisherVerification[Int] {
}
// FIXME verifyNoAsyncErrors() without delay is wrong in TCK, enable again in RC4
override def optional_spec111_maySupportMultiSubscribe(): Unit = ()
}

3
akka-stream-tck/src/test/scala/akka/stream/tck/IterablePublisherTest.scala
View file

@ -14,7 +14,4 @@ class IterablePublisherTest extends AkkaPublisherVerification[Int] {
Source(iterable(elements)).runWith(Sink.publisher)
}
// FIXME #16983
override def required_spec317_mustNotSignalOnErrorWhenPendingAboveLongMaxValue(): Unit = ()
}