reduce timeout to 100ms in DefaultStreamForwarderTest.streamWithTimeout

Signed-off-by: Cai Yufei <Yufei.Cai@bosch-si.com>
eclipse-ditto · Dec 14, 2017 · 4bd7a6b · 4bd7a6b
1 parent 5834488
commit 4bd7a6b
Showing 1 changed file with 8 additions and 4 deletions.
diff --git a/...test/java/org/eclipse/ditto/services/utils/akka/streaming/DefaultStreamForwarderTest.java b/...test/java/org/eclipse/ditto/services/utils/akka/streaming/DefaultStreamForwarderTest.java
@@ -67,7 +67,7 @@ public void tearDownBase() {
     public void streamWithTimeout() {
         new TestKit(actorSystem) {
             {
-                final ActorRef streamForwarder = createStreamForwarder();
+                final ActorRef streamForwarder = createStreamForwarder(Duration.ofMillis(100));
                 watch(streamForwarder);
 
                 streamForwarder.tell(KNOWN_TAG_1, ActorRef.noSender());
@@ -143,12 +143,16 @@ private StreamAck failureResponse(final String tag) {
         return StreamAck.failure(tag);
     }
 
-    private ActorRef createStreamForwarder() {
+    private ActorRef createStreamForwarder(final Duration maxIdleTime) {
         // for simplicity, just use String as elementClass
-        final Props props = DefaultStreamForwarder.props(recipient.ref(), completionRecipient.ref(), MAX_IDLE_TIME,
+        final Props props = DefaultStreamForwarder.props(recipient.ref(), completionRecipient.ref(), maxIdleTime,
                 String.class, String::toString);
 
         return actorSystem.actorOf(props);
     }
 
-}
+    private ActorRef createStreamForwarder() {
+        return createStreamForwarder(MAX_IDLE_TIME);
+    }
+
+}