diff --git a/reactor-net/src/test/java/reactor/io/net/tcp/SmokeTests.java b/reactor-net/src/test/java/reactor/io/net/tcp/SmokeTests.java
index <HASH>..<HASH> 100644
--- a/reactor-net/src/test/java/reactor/io/net/tcp/SmokeTests.java
+++ b/reactor-net/src/test/java/reactor/io/net/tcp/SmokeTests.java
@@ -267,9 +267,8 @@ public class SmokeTests {
 		  .doOnNext(d ->
 			  windows.getAndIncrement()
 		  )
-		  .flatMap(s -> s
-
-			  .reduce(new Buffer(), Buffer::append)
+		  .flatMap(s ->
+				  s.reduceWith(() -> new Buffer(), Buffer::append)
 		  )
 				.doOnNext(d ->
 								postReduce.getAndIncrement()
reduce(Supplier) as reduceWith