diff --git a/spring-web/src/test/java/org/springframework/http/server/reactive/MultipartIntegrationTests.java b/spring-web/src/test/java/org/springframework/http/server/reactive/MultipartIntegrationTests.java index 5f97aa889b9..a756612bc85 100644 --- a/spring-web/src/test/java/org/springframework/http/server/reactive/MultipartIntegrationTests.java +++ b/spring-web/src/test/java/org/springframework/http/server/reactive/MultipartIntegrationTests.java @@ -103,11 +103,12 @@ public class MultipartIntegrationTests extends AbstractHttpHandlerIntegrationTes assertEquals("fooPart", part.name()); assertTrue(part instanceof FilePart); assertEquals("foo.txt", ((FilePart) part).filename()); - DataBuffer buffer = DataBufferUtils.join(part.content()).block(); - assertEquals(12, buffer.readableByteCount()); - byte[] byteContent = new byte[12]; - buffer.read(byteContent); - assertEquals("Lorem Ipsum.", new String(byteContent)); + DataBufferUtils.join(part.content()).subscribe(buffer -> { + assertEquals(12, buffer.readableByteCount()); + byte[] byteContent = new byte[12]; + buffer.read(byteContent); + assertEquals("Lorem Ipsum.", new String(byteContent)); + }); } private void assertBarPart(Part part) {