We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent b80f2ac commit 6095902Copy full SHA for 6095902
src/protocol/mdns.rs
@@ -138,12 +138,15 @@ impl Mdns {
138
socket.join_multicast_v4(&IPV4_MULTICAST_ADDRESS, &Ipv4Addr::UNSPECIFIED)?;
139
socket.set_nonblocking(true)?;
140
141
+ let mut query_interval = tokio::time::interval(config.query_interval);
142
+ query_interval.set_missed_tick_behavior(tokio::time::MissedTickBehavior::Delay);
143
+
144
Ok(Self {
145
_transport_handle,
146
event_tx: config.tx,
147
next_query_id: 1337u16,
148
discovered: HashSet::new(),
- query_interval: tokio::time::interval(config.query_interval),
149
+ query_interval,
150
receive_buffer: vec![0u8; 4096],
151
username: rand::thread_rng()
152
.sample_iter(&Alphanumeric)
0 commit comments