We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent d6e22c5 commit 4764620Copy full SHA for 4764620
iroh/src/discovery.rs
@@ -429,6 +429,7 @@ impl ConcurrentDiscovery {
429
service.publish(data)
430
}
431
432
+ self.services.write().expect("poisoned").push(service);
433
434
435
/// Is there any services configured?
@@ -470,7 +471,6 @@ impl Discovery for ConcurrentDiscovery {
470
471
472
fn resolve(&self, node_id: NodeId) -> Option<BoxStream<Result<DiscoveryItem, DiscoveryError>>> {
473
let services = self.services.read().expect("poisoned");
- dbg!(services.len());
474
let streams = services
475
.iter()
476
.filter_map(|service| service.resolve(node_id));
0 commit comments