diff --git a/src/pipewire/stream.c b/src/pipewire/stream.c
index 613732b68..862e71bbd 100644
--- a/src/pipewire/stream.c
+++ b/src/pipewire/stream.c
@@ -1469,12 +1469,14 @@ static void node_state_changed(void *data, enum pw_node_state old,
 static void node_peer_added (void *data, struct pw_impl_node *node, uint32_t id)
 {
 	struct pw_stream *stream = data;
-	pw_stream_emit_peer_added(stream, id);
+	if (stream->node_id != SPA_ID_INVALID && id != stream->node_id)
+		pw_stream_emit_peer_added(stream, id);
 }
 static void node_peer_removed (void *data, struct pw_impl_node *node, uint32_t id)
 {
 	struct pw_stream *stream = data;
-	pw_stream_emit_peer_removed(stream, id);
+	if (stream->node_id != SPA_ID_INVALID && id != stream->node_id)
+		pw_stream_emit_peer_removed(stream, id);
 }
 
 static const struct pw_impl_node_events node_events = {