add sync lanes

1 files changed, 5 insertions, 1 deletions

diff --git a/src/node.rs b/src/node.rs
index 9200d16..5b55c8d 100644
--- a/src/node.rs
+++ b/src/node.rs
@@ -136,13 +136,17 @@ impl Node {
         let Self { state, sync_rx } = self;
 
         let consumer_state = state.clone();
+        let lanes = Arc::new(peer::SyncLanes::start(&state));
         tokio::spawn(async move {
             let inner_state = consumer_state.clone();
             let _ = consumer_state
                 .transport
                 .start_consumer(Box::new(move |sender, msg, _payload_len| {
                     let state_clone = inner_state.clone();
-                    Box::pin(async move { peer::handle_message(&state_clone, sender, msg).await })
+                    let lanes = Arc::clone(&lanes);
+                    Box::pin(async move {
+                        peer::handle_message(&state_clone, &lanes, sender, msg).await
+                    })
                 }))
                 .await;
         });