diff --git a/akka-docs/src/test/java/jdocs/stream/operators/flow/FromSinkAndSource.java b/akka-docs/src/test/java/jdocs/stream/operators/flow/FromSinkAndSource.java
index b3e7f7bfac..70bd28bed4 100644
--- a/akka-docs/src/test/java/jdocs/stream/operators/flow/FromSinkAndSource.java
+++ b/akka-docs/src/test/java/jdocs/stream/operators/flow/FromSinkAndSource.java
@@ -14,6 +14,8 @@ import akka.stream.testkit.TestSubscriber;
 import akka.util.ByteString;
 
 import java.time.Duration;
+import java.util.Collections;
+import java.util.Optional;
 import java.util.concurrent.CompletionStage;
 
 public class FromSinkAndSource {
@@ -31,7 +33,15 @@ public class FromSinkAndSource {
     Flow<ByteString, ByteString, NotUsed> serverFlow = Flow.fromSinkAndSource(sink, source);
 
     Source<Tcp.IncomingConnection, CompletionStage<Tcp.ServerBinding>> connectionStream =
-        Tcp.get(system).bind("127.0.0.1", 9999);
+        Tcp.get(system)
+            .bind(
+                "127.0.0.1", // interface
+                9999, // port
+                100, // backlog
+                Collections.emptyList(), // socket options
+                true, // Important: half close enabled
+                Optional.empty() // idle timeout
+                );
 
     connectionStream.runForeach(
         incomingConnection -> incomingConnection.handleWith(serverFlow, system), system);
diff --git a/akka-docs/src/test/scala/docs/stream/operators/flow/FromSinkAndSource.scala b/akka-docs/src/test/scala/docs/stream/operators/flow/FromSinkAndSource.scala
index 0fc745a3d4..c62c6506d9 100644
--- a/akka-docs/src/test/scala/docs/stream/operators/flow/FromSinkAndSource.scala
+++ b/akka-docs/src/test/scala/docs/stream/operators/flow/FromSinkAndSource.scala
@@ -34,7 +34,7 @@ object FromSinkAndSource {
 
     val serverFlow = Flow.fromSinkAndSource(sink, source)
 
-    Tcp().bind("127.0.0.1", 9999).runForeach { incomingConnection =>
+    Tcp().bind("127.0.0.1", 9999, halfClose = true).runForeach { incomingConnection =>
       incomingConnection.handleWith(serverFlow)
     }
     // #halfClosedTcpServer