From 2b8b946bc7dbf110a2553b6bcf7b45f743cbc92b Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Johan=20Andr=C3=A9n?= <johan@markatta.com>
Date: Mon, 19 Feb 2018 11:19:56 +0100
Subject: [PATCH] A bit more generous timeouts in RateTransformationDocSpec
 #24559 (#24564)

---
 .../docs/stream/RateTransformationDocSpec.scala     | 13 +++++--------
 1 file changed, 5 insertions(+), 8 deletions(-)

diff --git a/akka-docs/src/test/scala/docs/stream/RateTransformationDocSpec.scala b/akka-docs/src/test/scala/docs/stream/RateTransformationDocSpec.scala
index 989a0da05f..a71f05888f 100644
--- a/akka-docs/src/test/scala/docs/stream/RateTransformationDocSpec.scala
+++ b/akka-docs/src/test/scala/docs/stream/RateTransformationDocSpec.scala
@@ -16,15 +16,12 @@ import akka.testkit.{ AkkaSpec, TestLatch }
 
 class RateTransformationDocSpec extends AkkaSpec {
 
-  type Seq[+A] = immutable.Seq[A]
-  val Seq = immutable.Seq
-
   implicit val materializer = ActorMaterializer()
 
   "conflate should summarize" in {
     //#conflate-summarize
     val statsFlow = Flow[Double]
-      .conflateWithSeed(Seq(_))(_ :+ _)
+      .conflateWithSeed(immutable.Seq(_))(_ :+ _)
       .map { s ⇒
         val μ = s.sum / s.size
         val se = s.map(x ⇒ pow(x - μ, 2))
@@ -38,14 +35,14 @@ class RateTransformationDocSpec extends AkkaSpec {
       .grouped(10)
       .runWith(Sink.head)
 
-    Await.result(fut, 100.millis)
+    fut.futureValue
   }
 
   "conflate should sample" in {
     //#conflate-sample
     val p = 0.01
     val sampleFlow = Flow[Double]
-      .conflateWithSeed(Seq(_)) {
+      .conflateWithSeed(immutable.Seq(_)) {
         case (acc, elem) if Random.nextDouble < p ⇒ acc :+ elem
         case (acc, _)                             ⇒ acc
       }
@@ -57,7 +54,7 @@ class RateTransformationDocSpec extends AkkaSpec {
       .via(sampleFlow)
       .runWith(Sink.fold(Seq.empty[Double])(_ :+ _))
 
-    val count = Await.result(fut, 1000.millis).size
+    fut.futureValue
   }
 
   "expand should repeat last" in {
@@ -73,7 +70,7 @@ class RateTransformationDocSpec extends AkkaSpec {
       .run()
 
     probe.sendNext(1.0)
-    val expanded = Await.result(fut, 100.millis)
+    val expanded = fut.futureValue
     expanded.size shouldBe 10
     expanded.sum shouldBe 10
   }