diff --git a/src/lean_spec/subspecs/networking/client/reqresp_client.py b/src/lean_spec/subspecs/networking/client/reqresp_client.py
index adb8d09ff..b032d59c1 100644
--- a/src/lean_spec/subspecs/networking/client/reqresp_client.py
+++ b/src/lean_spec/subspecs/networking/client/reqresp_client.py
@@ -170,9 +170,7 @@ async def _do_blocks_by_root_request(
             await stream.write(request_bytes)
 
             # Half-close to signal we're done sending.
-            finish_write = getattr(stream, "finish_write", None)
-            if finish_write is not None:
-                await finish_write()
+            await stream.finish_write()
 
             # Read response chunks.
             #
@@ -297,9 +295,7 @@ async def _do_blocks_by_range_request(
             await stream.write(request_bytes)
 
             # Half-close to signal we're done sending.
-            finish_write = getattr(stream, "finish_write", None)
-            if finish_write is not None:
-                await finish_write()
+            await stream.finish_write()
 
             # Read response chunks.
             #
@@ -460,9 +456,7 @@ async def _do_status_request(
             await stream.write(request_bytes)
 
             # Half-close to signal we're done sending.
-            finish_write = getattr(stream, "finish_write", None)
-            if finish_write is not None:
-                await finish_write()
+            await stream.finish_write()
 
             # Read peer's status response.
             response_data = await stream.read()