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

Give the large source test some more time #27497 (#27524)

Browse source
This commit is contained in:
Johan Andrén 2019-08-20 12:48:14 +02:00 • committed by GitHub
parent e61ac07f7e
commit 2c9f0c9ff0
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
1 changed files with 5 additions and 7 deletions
Download patch file Download diff file Expand all files Collapse all files

12
akka-stream-tests/src/test/scala/akka/stream/scaladsl/FlowScanAsyncSpec.scala
View file

@ -11,14 +11,14 @@ import akka.stream.testkit.TestSubscriber.Probe
import akka.stream.testkit.Utils.TE
import akka.stream.testkit._
import akka.stream.testkit.scaladsl._
import akka.stream.{ ActorAttributes, ActorMaterializer, Supervision }
import org.scalatest.Matchers
import scala.collection.immutable
import scala.concurrent.{ Future, Promise }
import scala.concurrent.duration._
import scala.concurrent.{ Future, Promise }
import scala.util.Failure
class FlowScanAsyncSpec extends StreamSpec {
class FlowScanAsyncSpec extends StreamSpec with Matchers {
implicit val materializer: ActorMaterializer = ActorMaterializer()
implicit val executionContext = materializer.executionContext
@ -84,10 +84,8 @@ class FlowScanAsyncSpec extends StreamSpec {
"work with a large source" in {
val elements = 1 to 100000
val expectedSum = elements.sum
val eventualActual: Future[Int] = Source(elements).via(sumScanFlow).runWith(Sink.last)
whenReady(eventualActual) { actual =>
assert(actual === expectedSum)
}
val result = Source(elements).via(sumScanFlow).runWith(Sink.last).futureValue(timeout(patience.timeout * 2))
result should ===(expectedSum)
}
"work with slow futures" in {