diff --git a/src/proto_015_PtLimaPt/lib_delegate/node_rpc.ml b/src/proto_015_PtLimaPt/lib_delegate/node_rpc.ml
index badb4fc204d42364219001818f351c7c8daa0cb2..18c39e0316202f2cbee8cfcd35fe865c4a448111 100644
--- a/src/proto_015_PtLimaPt/lib_delegate/node_rpc.ml
+++ b/src/proto_015_PtLimaPt/lib_delegate/node_rpc.ml
@@ -206,6 +206,7 @@ let monitor_proposals cctxt ~chain () =
 
 let await_protocol_activation cctxt ~chain () =
   Monitor_services.heads cctxt ~next_protocols:[Protocol.hash] chain
-  >>=? fun (_block_stream, stop) ->
+  >>=? fun (block_stream, stop) ->
+  Lwt_stream.get block_stream >>= fun _ ->
   stop () ;
   return_unit
diff --git a/src/proto_016_PtMumbai/lib_delegate/node_rpc.ml b/src/proto_016_PtMumbai/lib_delegate/node_rpc.ml
index 754e96117c1141ffc3325d52fb7dc47c738ab2bc..a0c9cb5f2454a90d27cb6fb195c5c2b5ed5ab98d 100644
--- a/src/proto_016_PtMumbai/lib_delegate/node_rpc.ml
+++ b/src/proto_016_PtMumbai/lib_delegate/node_rpc.ml
@@ -278,6 +278,7 @@ let monitor_heads cctxt ~chain ?cache () =
 
 let await_protocol_activation cctxt ~chain () =
   Monitor_services.heads cctxt ~next_protocols:[Protocol.hash] chain
-  >>=? fun (_block_stream, stop) ->
+  >>=? fun (block_stream, stop) ->
+  Lwt_stream.get block_stream >>= fun _ ->
   stop () ;
   return_unit
diff --git a/src/proto_alpha/lib_delegate/node_rpc.ml b/src/proto_alpha/lib_delegate/node_rpc.ml
index 754e96117c1141ffc3325d52fb7dc47c738ab2bc..a0c9cb5f2454a90d27cb6fb195c5c2b5ed5ab98d 100644
--- a/src/proto_alpha/lib_delegate/node_rpc.ml
+++ b/src/proto_alpha/lib_delegate/node_rpc.ml
@@ -278,6 +278,7 @@ let monitor_heads cctxt ~chain ?cache () =
 
 let await_protocol_activation cctxt ~chain () =
   Monitor_services.heads cctxt ~next_protocols:[Protocol.hash] chain
-  >>=? fun (_block_stream, stop) ->
+  >>=? fun (block_stream, stop) ->
+  Lwt_stream.get block_stream >>= fun _ ->
   stop () ;
   return_unit