add support for several transports

1 files changed, 7 insertions, 1 deletions

diff --git a/src/swarm/topology.rs b/src/swarm/topology.rs
index bdfeb53..5150e38 100644
--- a/src/swarm/topology.rs
+++ b/src/swarm/topology.rs
@@ -144,9 +144,15 @@ pub(crate) async fn refresh(state: &AppState) -> Option<NeighbourChange> {
         (current, stable)
     };
     let k = state.neighbours_k;
+    // Those that don't answer, and those on none of our transports.
     let mut unreachable = BTreeSet::new();
     for member in &current {
-        if let Some(peer_state) = state.get_peer_state(member).await
+        if member == state.local_id() {
+            continue;
+        }
+        if !state.transport.can_reach(member) {
+            unreachable.insert(member.clone());
+        } else if let Some(peer_state) = state.get_peer_state(member).await
             && peer_state.lock().await.is_unreachable()
         {
             unreachable.insert(member.clone());