Merge branch '0.8.x'

reactor · Oct 24, 2019 · 0e0336f · 0e0336f
2 parents dc17ab1 + 928f271
commit 0e0336f
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/src/test/java/reactor/netty/channel/ChannelOperationsHandlerTest.java b/src/test/java/reactor/netty/channel/ChannelOperationsHandlerTest.java
@@ -31,6 +31,7 @@
 import java.util.concurrent.atomic.AtomicInteger;
 
 import io.netty.channel.ChannelHandler;
+import io.netty.handler.codec.LineBasedFrameDecoder;
 import io.netty.handler.codec.http.HttpMethod;
 import io.netty.handler.timeout.WriteTimeoutHandler;
 import org.junit.Test;
@@ -84,13 +85,14 @@ private void doTestPublisherSenderOnCompleteFlushInProgress(boolean useScheduler
 				          .wiretap(true)
 				          .bindNow(Duration.ofSeconds(30));
 
-		Flux<String> flux = Flux.range(1, 257).map(count -> count + "");
+		Flux<String> flux = Flux.range(1, 257).map(count -> count + "\n");
 		if (useScheduler) {
 			flux.publishOn(Schedulers.single());
 		}
 		Mono<Integer> code =
 				HttpClient.create()
 				          .tcpConfiguration(tcpClient -> tcpClient.doOnConnected(conn -> {
+					          conn.addHandler(new LineBasedFrameDecoder(10));
 				              if (handler != null) {
 				                  conn.addHandlerLast(handler);
 				              }