aboutsummaryrefslogtreecommitdiffstats
path: root/src/node.rs
diff options
context:
space:
mode:
authortv <tv@krebsco.de>2026-10-31 03:56:30 +0100
committertv <tv@krebsco.de>2026-10-31 03:56:30 +0100
commit2daaab15a336d4fa6fae62b28702e23dc12571ae (patch)
tree601dc54c1f21a1757e4f188592327a3d48de26f4 /src/node.rs
parent73d071fda276f8d2d948e246e006e5604f2c5742 (diff)
move change publisher to own module
Diffstat (limited to 'src/node.rs')
-rw-r--r--src/node.rs4
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()));
}