Merge pull request #19546 from akka/wip-19544-FlowExpandSpec-RK

#19544 fix FlowExpandSpec
2016-01-21 09:17:22 +01:00 · 2016-01-21 09:17:22 +01:00 · 63d366f4c1
commit 63d366f4c1
parent b1351b36ed 75a18ba6c8
1 changed files with 2 additions and 2 deletions
--- a/akka-stream-tests/src/test/scala/akka/stream/scaladsl/FlowExpandSpec.scala
+++ b/akka-stream-tests/src/test/scala/akka/stream/scaladsl/FlowExpandSpec.scala
@ -135,9 +135,9 @@ class FlowExpandSpec extends AkkaSpec {
      source
        .sendNext(1)
      sink
-        .request(5)
+        .request(4)
        .expectNext(1 -> 0, 1 -> 1, 1 -> 2)
-        .expectNoMsg(300.millis)
+        .expectNoMsg(100.millis)
      source
        .sendNext(2)
        .sendComplete()