Update base_layer/core/src/mempool/sync_protocol/initializer.rs

Co-authored-by: Stan Bondi <sdbondi@users.noreply.github.com>
tari-project · Sep 23, 2022 · f5ac3af · f5ac3af
1 parent 1a027d5
commit f5ac3af
Showing 1 changed file with 4 additions and 6 deletions.
diff --git 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;
         });