diff options
| author | tv <tv@krebsco.de> | 2026-11-06 19:54:09 +0100 |
|---|---|---|
| committer | tv <tv@krebsco.de> | 2026-11-06 19:54:09 +0100 |
| commit | 5994b49412c058079639585501a78e6458fdbb6f (patch) | |
| tree | ca78aa3cd7d0d6d2a48bfa42d61afcddb8efd6df /src/swarm/relay.rs | |
| parent | 7c0c318dca3054be6c7bacf5a4b3f5a4e47cc949 (diff) | |
HyParView (slim)
Diffstat (limited to 'src/swarm/relay.rs')
| -rw-r--r-- | src/swarm/relay.rs | 4 |
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()) |
