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

#20627: Increase LayoutSpec stresstest patience

Browse source
This commit is contained in:
Endre Sándor Varga 2016-05-31 14:45:25 +02:00
parent 36516530a0
commit 38c7627ddc
1 changed files with 11 additions and 6 deletions
Download patch file Download diff file Expand all files Collapse all files

17
akka-stream-tests/src/test/scala/akka/stream/impl/StreamLayoutSpec.scala
View file

@ -8,6 +8,8 @@ import akka.testkit.AkkaSpec
import org.reactivestreams.{ Subscription, Subscriber, Publisher }
import akka.stream._
import scala.concurrent.duration._
class StreamLayoutSpec extends AkkaSpec {
import StreamLayout._
@ -123,6 +125,9 @@ class StreamLayoutSpec extends AkkaSpec {
}
}
// Seen tests run in 9-10 seconds, these test cases are heavy on the GC
val veryPatient = PatienceConfig(20.seconds)
"not fail materialization when building a large graph with simple computation" when {
"starting from a Source" in {
@ -131,14 +136,14 @@ class StreamLayoutSpec extends AkkaSpec {
(f, i) ⇒ f.map(identity))
val (mat, fut) = g.toMat(Sink.seq)(Keep.both).run()
mat should ===(1)
fut.futureValue should ===(List(42))
fut.futureValue(veryPatient) should ===(List(42))
}
"starting from a Flow" in {
val g = (1 to tooDeepForStack).foldLeft(Flow[Int])((f, i) ⇒ f.map(identity))
val (mat, fut) = g.runWith(Source.single(42).mapMaterializedValue(_ ⇒ 1), Sink.seq)
mat should ===(1)
fut.futureValue should ===(List(42))
fut.futureValue(veryPatient) should ===(List(42))
}
"using .via" in {
@ -147,7 +152,7 @@ class StreamLayoutSpec extends AkkaSpec {
(f, i) ⇒ f.via(Flow[Int].map(identity)))
val (mat, fut) = g.toMat(Sink.seq)(Keep.both).run()
mat should ===(1)
fut.futureValue should ===(List(42))
fut.futureValue(veryPatient) should ===(List(42))
}
}
@ -159,14 +164,14 @@ class StreamLayoutSpec extends AkkaSpec {
(f, i) ⇒ f.map(identity)))
val (mat, fut) = g.toMat(Sink.seq)(Keep.both).run()
mat should ===(1)
fut.futureValue should ===(List(42))
fut.futureValue(veryPatient) should ===(List(42))
}
"starting from a Flow" in {
val g = Flow fromGraph Fusing.aggressive((1 to tooDeepForStack).foldLeft(Flow[Int])((f, i) ⇒ f.map(identity)))
val (mat, fut) = g.runWith(Source.single(42).mapMaterializedValue(_ ⇒ 1), Sink.seq)
mat should ===(1)
fut.futureValue should ===(List(42))
fut.futureValue(veryPatient) should ===(List(42))
}
"using .via" in {
@ -175,7 +180,7 @@ class StreamLayoutSpec extends AkkaSpec {
(f, i) ⇒ f.via(Flow[Int].map(identity))))
val (mat, fut) = g.toMat(Sink.seq)(Keep.both).run()
mat should ===(1)
fut.futureValue should ===(List(42))
fut.futureValue(veryPatient) should ===(List(42))
}
}