diff options
| author | tv <tv@krebsco.de> | 2026-10-27 00:33:03 +0100 |
|---|---|---|
| committer | tv <tv@krebsco.de> | 2026-10-27 00:33:03 +0100 |
| commit | 7af8f58d46737bb5835aa1625485f22ecf374ebe (patch) | |
| tree | 4a2c82a4cc83fa7c14673f98a14c81d3ff0822a0 /src/main.rs | |
| parent | ef4ec226ef720f4c3bdba5ae534465f67cda04ee (diff) | |
add Transport::delivery_limit
Diffstat (limited to 'src/main.rs')
| -rw-r--r-- | src/main.rs | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/src/main.rs b/src/main.rs index 76086ca..dade8bc 100644 --- a/src/main.rs +++ b/src/main.rs @@ -159,6 +159,7 @@ async fn main() -> Result<()> { let mycelium_transport = Arc::new(mycelium::MyceliumTransport::connect(mycelium_setup).await?); debug!(local_id = mycelium_transport.local_id(), "Transport ready"); + let delivery_limit = mycelium_transport.delivery_limit(); let document_file = args.document_file.clone().map(|path| { Arc::new(document::file::DocumentFile::new( @@ -173,7 +174,7 @@ async fn main() -> Result<()> { initial_epoch, initial_doc, earlier_actors, - timing: state::Timing::from_keepalive(args.keepalive), + timing: state::Timing::from_keepalive(args.keepalive, delivery_limit), neighbours_k: args.neighbours, alias: args.alias.clone(), electorate_window: args.electorate_window, |
