diff --git a/spring-core/src/test/java/org/springframework/core/io/buffer/support/DataBufferUtilsTests.java b/spring-core/src/test/java/org/springframework/core/io/buffer/support/DataBufferUtilsTests.java index caf24b4c61..602020e377 100644 --- a/spring-core/src/test/java/org/springframework/core/io/buffer/support/DataBufferUtilsTests.java +++ b/spring-core/src/test/java/org/springframework/core/io/buffer/support/DataBufferUtilsTests.java @@ -61,16 +61,15 @@ public class DataBufferUtilsTests extends AbstractDataBufferAllocatingTestCase { .toURI(); FileChannel channel = FileChannel.open(Paths.get(uri), StandardOpenOption.READ); - Flux flux = DataBufferUtils.read(channel, this.bufferFactory, 2); + Flux flux = DataBufferUtils.read(channel, this.bufferFactory, 5); TestSubscriber .subscribe(flux) .assertNoError() .assertComplete() .assertValuesWith( - stringConsumer("fo"), stringConsumer("ob"), - stringConsumer("ar"), stringConsumer("ba"), - stringConsumer("zq"), stringConsumer("ux") + stringConsumer("fooba"), stringConsumer("rbazq"), + stringConsumer("ux") ); assertFalse(channel.isOpen());