diff --git a/packages/core/src/com/communication.ts b/packages/core/src/com/communication.ts
index 437ea10ec..631b4d2a9 100644
--- a/packages/core/src/com/communication.ts
+++ b/packages/core/src/com/communication.ts
@@ -274,12 +274,12 @@ export class Communication {
                 const callback = args[0] as UnknownFunction;
                 let wrapedCallback = fnHandlers.get(callback);
                 if (!wrapedCallback) {
-                    wrapedCallback = (value, version) => {
+                    wrapedCallback = (value, version, ...callbackArgs) => {
                         this.remoteValueTracking.set(handlerId, {
                             currentVersion: version,
                             reconnect,
                         });
-                        return callback(value, version);
+                        return callback(value, version, ...callbackArgs);
                     };
                     fnHandlers.set(callback, wrapedCallback);
                 }
@@ -1085,16 +1085,6 @@ export class Communication {
 
         return handlerId;
     }
-
-    private isRemoteValueSubscription(method: string): boolean {
-        return method.endsWith('.subscribe') || method.endsWith('.stream');
-    }
-
-    private getRemoteValuePropertyName(method: string): string {
-        // Extract property name from 'propertyName.subscribe' or 'propertyName.stream'
-        const parts = method.split('.');
-        return parts.slice(0, -1).join('.');
-    }
     private createCallbackRecord(
         message: Message,
         callbackId: string,
diff --git a/packages/core/src/remote-value.ts b/packages/core/src/remote-value.ts
index 355050695..3361dbd80 100644
--- a/packages/core/src/remote-value.ts
+++ b/packages/core/src/remote-value.ts
@@ -1,4 +1,4 @@
-export type RemoteValueListener<T> = (data: T, version: number) => void;
+export type RemoteValueListener<T> = (data: T, version: number, modifier?: string) => void;
 export type ReconnectFunction<T> = (currentVersion: number) => Promise<{
     value: T;
     version: number;