diff options
| author | tv <tv@krebsco.de> | 2026-10-30 21:47:31 +0100 |
|---|---|---|
| committer | tv <tv@krebsco.de> | 2026-10-30 21:47:31 +0100 |
| commit | 85af878f85a699ed8b414a6f8d84723ba3f8ab7a (patch) | |
| tree | 480faf82c57807e89ac6c5bf6cd108bf51a0ff2c /src/node.rs | |
| parent | 005ef0d27363d63b3cd2cd44658d54ac75ea1c2d (diff) | |
allow links subscriptions
Diffstat (limited to 'src/node.rs')
| -rw-r--r-- | src/node.rs | 3 |
1 files changed, 3 insertions, 0 deletions
diff --git a/src/node.rs b/src/node.rs index be722e6..0b8f663 100644 --- a/src/node.rs +++ b/src/node.rs @@ -171,6 +171,9 @@ impl Node { }); trace!("Sync worker task spawned"); + // Subscribers to our links (`swarm::links`; any build has them). + tokio::spawn(crate::swarm::links::watch(state.clone())); + let peer_worker_state = state.clone(); tokio::spawn(async move { peer::run_peer_worker(peer_worker_state).await; |
