+stk add missing TestSubscriber.requestNext() method

2015-08-20 16:13:04 +02:00 · 2015-08-20 16:13:04 +02:00 · 51f1d36852
commit 51f1d36852
parent 7df6fa9e32
1 changed files with 5 additions and 0 deletions
--- a/akka-stream-testkit/src/main/scala/akka/stream/testkit/StreamTestKit.scala
+++ b/akka-stream-testkit/src/main/scala/akka/stream/testkit/StreamTestKit.scala
@ -353,6 +353,11 @@ object TestSubscriber {
      subscription.cancel()
      this
    }
+
+    def requestNext(): T = {
+      subscription.request(1)
+      expectNext()
+    }
  }
 }