From 485c3be4da9347f0e348701d18665d99c005586e Mon Sep 17 00:00:00 2001
From: Dawid Jenczewski <djenczewski@simplito.com>
Date: Thu, 12 Mar 2026 14:27:11 +0100
Subject: [PATCH 1/2] feat(privmx-endpoint): replace StreamNewStreamsEvent to
 RemoteStreamsChangedEven

---
 jni-wrappers/privmx-endpoint/src/cpp/parsers/parser.cpp    | 7 ++++---
 .../java/privmx_endpoint_extra/events/EventType.java       | 4 ++--
 2 files changed, 6 insertions(+), 5 deletions(-)

diff --git a/jni-wrappers/privmx-endpoint/src/cpp/parsers/parser.cpp b/jni-wrappers/privmx-endpoint/src/cpp/parsers/parser.cpp
index 80685fbc..7cffc7b4 100644
--- a/jni-wrappers/privmx-endpoint/src/cpp/parsers/parser.cpp
+++ b/jni-wrappers/privmx-endpoint/src/cpp/parsers/parser.cpp
@@ -749,9 +749,10 @@ parseEvent(JniContextUtils &ctx, std::shared_ptr<privmx::endpoint::core::Event>
                     event_cast.timestamp,
                     privmx::wrapper::streamEventData2Java(ctx, event_cast.data)
             );
-        } else if (stream::Events::isStreamNewStreamsEvent(event)) {
-            privmx::endpoint::stream::StreamNewStreamsEvent event_cast =
-                    stream::Events::extractStreamNewStreamsEvent(event);
+        }
+        else if (stream::Events::isRemoteStreamsChangedEvent(event)) {
+            privmx::endpoint::stream::RemoteStreamsChangedEvent event_cast =
+                    stream::Events::extractRemoteStreamsChangedEvent(event);
 
             return initEvent(
                     ctx,
diff --git a/privmx-endpoint-extra/src/main/java/com/simplito/java/privmx_endpoint_extra/events/EventType.java b/privmx-endpoint-extra/src/main/java/com/simplito/java/privmx_endpoint_extra/events/EventType.java
index 87a26d18..07aa5653 100644
--- a/privmx-endpoint-extra/src/main/java/com/simplito/java/privmx_endpoint_extra/events/EventType.java
+++ b/privmx-endpoint-extra/src/main/java/com/simplito/java/privmx_endpoint_extra/events/EventType.java
@@ -799,9 +799,9 @@ public static EventType<StreamLeftEventData> StreamLeftEvent(StreamEventSelector
         );
     }
 
-    public static EventType<NewStreams> StreamNewStreamsEvent(StreamEventSelectorType selectorType, String selectorId) {
+    public static EventType<NewStreams> RemoteStreamsChangedEvent(StreamEventSelectorType selectorType, String selectorId) {
         return new EventType<>(
-                "StreamNewStreams",
+                "remoteStreamsChanged",
                 StreamEventType.STREAMROOM_UPDATE,
                 selectorType,
                 selectorId,

From f5b501cf4b1f08e151eb981cccaad352c701592f Mon Sep 17 00:00:00 2001
From: Dawid Jenczewski <djenczewski@simplito.com>
Date: Thu, 12 Mar 2026 14:29:23 +0100
Subject: [PATCH 2/2] feat(privmx-endpoint-extra): add filter by eventType
 while getting list of callbacks

---
 .../java/privmx_endpoint_extra/events/EventDispatcher.java | 7 ++++---
 1 file changed, 4 insertions(+), 3 deletions(-)

diff --git a/privmx-endpoint-extra/src/main/java/com/simplito/java/privmx_endpoint_extra/events/EventDispatcher.java b/privmx-endpoint-extra/src/main/java/com/simplito/java/privmx_endpoint_extra/events/EventDispatcher.java
index 57042f74..63f2248f 100644
--- a/privmx-endpoint-extra/src/main/java/com/simplito/java/privmx_endpoint_extra/events/EventDispatcher.java
+++ b/privmx-endpoint-extra/src/main/java/com/simplito/java/privmx_endpoint_extra/events/EventDispatcher.java
@@ -71,7 +71,7 @@ public EventRegistrationInfo registerCallback(CallbackRegistration<?> callbackRe
      * @param event event data to emit
      */
     public <T> void emit(Event<T> event) {
-        List<Pair> callbacks = EventType.isLibEvent(event) ? getCallbacksByType(event.type) : getCallbacks(event.subscriptions);
+        List<Pair> callbacks = EventType.isLibEvent(event) ? getCallbacksByType(event.type) : getCallbacks(event.subscriptions,event.type);
         for (Pair p : callbacks) {
             try {
                 EventCallback<T> e = (EventCallback<T>) p.callback;
@@ -154,12 +154,13 @@ private List<Pair> getCallbackList(EventRegistrationInfo eventRegistrationInfo)
     /**
      * Get list of all callbacks identified by this subscriptionIds.
      */
-    private List<Pair> getCallbacks(List<String> subscriptionIds) {
+    private List<Pair> getCallbacks(List<String> subscriptionIds, String eventType) {
         synchronized (callbackMap) {
             return callbackMap.entrySet()
                     .stream()
                     .filter(it ->
-                        it.getKey().subscriptionID != null && subscriptionIds.contains(it.getKey().subscriptionID)
+                        it.getKey().subscriptionID != null && subscriptionIds.contains(it.getKey().subscriptionID) &&
+                                it.getKey().eventType.eventName.equals(eventType)
                     )
                     .flatMap(it -> it.getValue().stream())
                     .collect(Collectors.toList());