root
/
spring-framework
mirror of https://github.com/spring-projects/spring-framework.git
1
0
Fork 0
Code Issues Actions Packages Projects Releases Wiki Activity

Add timeout to DataBufferUtilsTests to avoid hanging

This commit is contained in:
Rossen Stoyanchev 2017-07-14 23:07:48 +02:00
parent 47b63150d1
commit d3749bc1ec
1 changed files with 13 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

24
spring-core/src/test/java/org/springframework/core/io/buffer/DataBufferUtilsTests.java
View File

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