diff --git a/base_layer/core/src/mempool/sync_protocol/initializer.rs b/base_layer/core/src/mempool/sync_protocol/initializer.rs
index bd89725d80..7ca978d234 100644
--- a/base_layer/core/src/mempool/sync_protocol/initializer.rs
+++ b/base_layer/core/src/mempool/sync_protocol/initializer.rs
@@ -104,12 +104,10 @@ impl ServiceInitializer for MempoolSyncInitializer {
                 }
                 log_mdc::extend(mdc.clone());
             }
-            let streams = MempoolSyncStreams {
-                block_event_stream: base_node.get_block_event_stream(),
-                connectivity_events: connectivity_event_subscription,
-            };
-            MempoolSyncProtocol::new(config, notif_rx, mempool, connectivity)
-                .run(streams)
+           let base_node_events = base_node.get_block_event_stream();
+
+            MempoolSyncProtocol::new(config, notif_rx, mempool, connectivity, base_node_events)
+                .run()
                 .await;
         });