Skip to content
Open
Changes from 1 commit
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Prev Previous commit
Next Next commit
add periods to doc comments
  • Loading branch information
“ramfox” committed Nov 21, 2025
commit 3dad85a50ea13afe6002ce8138f5bd53f1b08d8d
12 changes: 6 additions & 6 deletions iroh/src/discovery/mdns.rs
Original file line number Diff line number Diff line change
Expand Up @@ -77,7 +77,7 @@ use crate::{
discovery::{Discovery, DiscoveryItem, EndpointData, EndpointInfo},
};

/// The n0 local service name
/// The n0 local service name.
const N0_SERVICE_NAME: &str = "irohv1";

/// Name of this discovery service.
Expand All @@ -95,10 +95,10 @@ const USER_DATA_ATTRIBUTE: &str = "user-data";
/// the TXT record supported by swarm-discovery.
const RELAY_URL_ATTRIBUTE: &str = "relay";

/// How long we will wait before we stop sending discovery items
/// How long we will wait before we stop sending discovery items.
const DISCOVERY_DURATION: Duration = Duration::from_secs(10);

/// Discovery using `swarm-discovery`, a variation on mdns
/// Discovery using `swarm-discovery`, a variation on mdns.
#[derive(Debug, Clone)]
pub struct MdnsDiscovery {
#[allow(dead_code)]
Expand Down Expand Up @@ -129,7 +129,7 @@ impl Subscribers {
Self(vec![])
}

/// Add the subscriber to the list of subscribers
/// Add the subscriber to the list of subscribers.
fn push(&mut self, subscriber: mpsc::Sender<DiscoveryEvent>) {
self.0.push(subscriber);
}
Expand Down Expand Up @@ -471,7 +471,7 @@ impl MdnsDiscovery {
})
}

/// Subscribe to discovered endpoints
/// Subscribe to discovered endpoints.
pub async fn subscribe(&self) -> impl Stream<Item = DiscoveryEvent> + Unpin + use<> {
let (sender, recv) = mpsc::channel(20);
let discovery_sender = self.sender.clone();
Expand Down Expand Up @@ -607,7 +607,7 @@ impl Discovery for MdnsDiscovery {
mod tests {

/// This module's name signals nextest to run test in a single thread (no other concurrent
/// tests)
/// tests).
mod run_in_isolation {
use iroh_base::{SecretKey, TransportAddr};
use n0_error::{AnyError as Error, Result, StdResultExt, bail_any};
Expand Down
Loading