From 35ce1945e0d9ff3c1010fb1a97818a6439398278 Mon Sep 17 00:00:00 2001 From: Arjen Poutsma Date: Tue, 19 Jul 2016 11:11:05 +0200 Subject: [PATCH] Improved DataBufferUtilsTest --- .../core/io/buffer/support/DataBufferUtilsTests.java | 7 +++---- 1 file changed, 3 insertions(+), 4 deletions(-) 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());