diff --git a/rnex-core/src/nex/matchmake.rs b/rnex-core/src/nex/matchmake.rs
index 085c8a1..e1afa21 100644
--- a/rnex-core/src/nex/matchmake.rs
+++ b/rnex-core/src/nex/matchmake.rs
@@ -235,10 +235,11 @@ impl ExtendedMatchmakeSession {
                 continue;
             }*/
 
+            if other_conn.pid != self.session.gathering.host_pid {
+                continue;
+            }
+
             for pid in &list_of_connected_pids {
-                if other_conn.pid == *pid {
-                    continue;
-                }
                 other_conn
                     .remote
                     .process_notification_event(NotificationEvent {
@@ -261,9 +262,6 @@ impl ExtendedMatchmakeSession {
                 continue;
             }
             for new_conn_pid in conns.iter().filter_map(Weak::upgrade).map(|c| c.pid) {
-                if old_conns.pid == new_conn_pid {
-                    continue;
-                }
                 old_conns
                     .remote
                     .process_notification_event(NotificationEvent {