diff options
Diffstat (limited to 'src/node.rs')
| -rw-r--r-- | src/node.rs | 6 |
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; }); |