aboutsummaryrefslogtreecommitdiffstats
path: root/src/swarm/relay.rs
diff options
context:
space:
mode:
authortv <tv@krebsco.de>2026-11-06 19:54:09 +0100
committertv <tv@krebsco.de>2026-11-06 19:54:09 +0100
commit5994b49412c058079639585501a78e6458fdbb6f (patch)
treeca78aa3cd7d0d6d2a48bfa42d61afcddb8efd6df /src/swarm/relay.rs
parent7c0c318dca3054be6c7bacf5a4b3f5a4e47cc949 (diff)
HyParView (slim)
Diffstat (limited to 'src/swarm/relay.rs')
-rw-r--r--src/swarm/relay.rs4
1 files changed, 2 insertions, 2 deletions
diff --git a/src/swarm/relay.rs b/src/swarm/relay.rs
index bee8687..5f7b8c0 100644
--- a/src/swarm/relay.rs
+++ b/src/swarm/relay.rs
@@ -158,7 +158,7 @@ pub(crate) async fn announce(
let mut treeless = unauthored || writers.is_empty();
for (writer, changes) in writers {
match state
- .dissemination
+ .dissemination()
.forward(state, *writer, from, changes)
.await
{
@@ -338,7 +338,7 @@ pub(crate) async fn pull_after_grace(state: &AppState, peer: &str, remote: &tran
crate::document::changes::missing(&replica.doc, remote.heads.listed())
};
if !missing.is_empty() {
- state.dissemination.announced(peer, &missing);
+ state.dissemination().announced(peer, &missing);
let grace = state
.lock_rtt()
.effective(peer, Instant::now(), state.timing.rtt_fresh_for())