From 51f1d368520cbad5b77be1d9453ebdcc1ef8f9f0 Mon Sep 17 00:00:00 2001
From: Johannes Rudolph <johannes.rudolph@gmail.com>
Date: Thu, 20 Aug 2015 16:13:04 +0200
Subject: [PATCH] +stk add missing `TestSubscriber.requestNext()` method

---
 .../src/main/scala/akka/stream/testkit/StreamTestKit.scala   | 5 +++++
 1 file changed, 5 insertions(+)

diff --git a/akka-stream-testkit/src/main/scala/akka/stream/testkit/StreamTestKit.scala b/akka-stream-testkit/src/main/scala/akka/stream/testkit/StreamTestKit.scala
index da7b687238..f2f37b4716 100644
--- 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()
+    }
   }
 }