diff options
| author | tv <tv@krebsco.de> | 2026-10-31 03:56:30 +0100 |
|---|---|---|
| committer | tv <tv@krebsco.de> | 2026-10-31 03:56:30 +0100 |
| commit | e197b04b0eb498298fbfe14d8f034dc84dc89e1e (patch) | |
| tree | 1f40ebef9e6d39808156545f5c080e5cb1bd95f2 /src/node.rs | |
| parent | d59cec8e6fd56bfbe91e251ec35e3e3e1f3f95dd (diff) | |
move change publisher to own module
Diffstat (limited to 'src/node.rs')
| -rw-r--r-- | src/node.rs | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/src/node.rs b/src/node.rs index 8adab2b..acf1dc5 100644 --- a/src/node.rs +++ b/src/node.rs @@ -21,7 +21,7 @@ use crate::state::{AppState, NodeLifecycle, Timing}; use crate::swarm::auth::SwarmKey; use crate::swarm::state_file::StateFile; use crate::swarm::sync::SyncEvent; -use crate::swarm::{self, peer, sync}; +use crate::swarm::{self, changes, peer, sync}; use crate::transport::Transport; use crate::transport::firewall::Firewall; use crate::transport::identity::{IdentityConfig, IdentityTransport}; @@ -194,6 +194,6 @@ impl Node { /// from then on, and it avoids diffing the initial sync) and the document file writer. pub(crate) fn spawn_ready_workers(state: &AppState) { let publisher_state = state.clone(); - tokio::spawn(async move { sync::run_change_publisher(publisher_state).await }); + tokio::spawn(async move { changes::run_change_publisher(publisher_state).await }); tokio::spawn(crate::document::file::run(state.clone())); } |
