From d3749bc1ec33e444c6b7ae41a6287ae642497c6f Mon Sep 17 00:00:00 2001
From: Rossen Stoyanchev <rstoyanchev@pivotal.io>
Date: Fri, 14 Jul 2017 23:07:48 +0200
Subject: [PATCH] Add timeout to DataBufferUtilsTests to avoid hanging

---
 .../core/io/buffer/DataBufferUtilsTests.java  | 24 ++++++++++---------
 1 file changed, 13 insertions(+), 11 deletions(-)

diff --git a/spring-core/src/test/java/org/springframework/core/io/buffer/DataBufferUtilsTests.java b/spring-core/src/test/java/org/springframework/core/io/buffer/DataBufferUtilsTests.java
index 953708dd67..41b679dab5 100644
--- a/spring-core/src/test/java/org/springframework/core/io/buffer/DataBufferUtilsTests.java
+++ b/spring-core/src/test/java/org/springframework/core/io/buffer/DataBufferUtilsTests.java
@@ -27,6 +27,7 @@ import java.nio.file.Files;
 import java.nio.file.Path;
 import java.nio.file.Paths;
 import java.nio.file.StandardOpenOption;
+import java.time.Duration;
 import java.util.stream.Collectors;
 
 import org.junit.Test;
@@ -52,7 +53,7 @@ public class DataBufferUtilsTests extends AbstractDataBufferAllocatingTestCase {
 				.consumeNextWith(stringConsumer("baz"))
 				.consumeNextWith(stringConsumer("qux"))
 				.expectComplete()
-				.verify();
+				.verify(Duration.ofSeconds(5));
 
 		assertFalse(channel.isOpen());
 	}
@@ -70,7 +71,7 @@ public class DataBufferUtilsTests extends AbstractDataBufferAllocatingTestCase {
 				.consumeNextWith(stringConsumer("baz"))
 				.consumeNextWith(stringConsumer("qux"))
 				.expectComplete()
-				.verify();
+				.verify(Duration.ofSeconds(5));
 	}
 
 	@Test
@@ -85,7 +86,7 @@ public class DataBufferUtilsTests extends AbstractDataBufferAllocatingTestCase {
 				.consumeNextWith(stringConsumer("baz"))
 				.consumeNextWith(stringConsumer("qux"))
 				.expectComplete()
-				.verify();
+				.verify(Duration.ofSeconds(5));
 	}
 
 	@Test
@@ -99,7 +100,7 @@ public class DataBufferUtilsTests extends AbstractDataBufferAllocatingTestCase {
 				.consumeNextWith(stringConsumer("rbazq"))
 				.consumeNextWith(stringConsumer("ux"))
 				.expectComplete()
-				.verify();
+				.verify(Duration.ofSeconds(5));
 
 		assertFalse(channel.isOpen());
 	}
@@ -115,7 +116,7 @@ public class DataBufferUtilsTests extends AbstractDataBufferAllocatingTestCase {
 				.consumeNextWith(stringConsumer("baz"))
 				.consumeNextWith(stringConsumer("qux"))
 				.expectComplete()
-				.verify();
+				.verify(Duration.ofSeconds(5));
 	}
 
 	@Test
@@ -136,7 +137,7 @@ public class DataBufferUtilsTests extends AbstractDataBufferAllocatingTestCase {
 				.consumeNextWith(stringConsumer("baz"))
 				.consumeNextWith(stringConsumer("qux"))
 				.expectComplete()
-				.verify();
+				.verify(Duration.ofSeconds(5));
 
 		String result = Files.readAllLines(tempFile)
 				.stream()
@@ -164,7 +165,7 @@ public class DataBufferUtilsTests extends AbstractDataBufferAllocatingTestCase {
 				.consumeNextWith(stringConsumer("baz"))
 				.consumeNextWith(stringConsumer("qux"))
 				.expectComplete()
-				.verify();
+				.verify(Duration.ofSeconds(5));
 
 		String result = Files.readAllLines(tempFile)
 				.stream()
@@ -193,7 +194,7 @@ public class DataBufferUtilsTests extends AbstractDataBufferAllocatingTestCase {
 				.consumeNextWith(stringConsumer("baz"))
 				.consumeNextWith(stringConsumer("qux"))
 				.expectComplete()
-				.verify();
+				.verify(Duration.ofSeconds(5));
 
 		String result = Files.readAllLines(tempFile)
 				.stream()
@@ -214,7 +215,8 @@ public class DataBufferUtilsTests extends AbstractDataBufferAllocatingTestCase {
 		StepVerifier.create(result)
 				.consumeNextWith(stringConsumer("foo"))
 				.consumeNextWith(stringConsumer("ba"))
-				.expectComplete().verify();
+				.expectComplete()
+				.verify(Duration.ofSeconds(5));
 
 		release(baz);
 	}
@@ -231,7 +233,7 @@ public class DataBufferUtilsTests extends AbstractDataBufferAllocatingTestCase {
 				.consumeNextWith(stringConsumer("r"))
 				.consumeNextWith(stringConsumer("baz"))
 				.expectComplete()
-				.verify();
+				.verify(Duration.ofSeconds(5));
 	}
 
 	@Test
@@ -245,7 +247,7 @@ public class DataBufferUtilsTests extends AbstractDataBufferAllocatingTestCase {
 		StepVerifier.create(result)
 				.expectNextCount(0)
 				.expectComplete()
-				.verify();
+				.verify(Duration.ofSeconds(5));
 	}
 
 	@Test