Fixed async remote callbacks

WebReflection · WebReflection · commit 663a3e594416 · 2025-07-08T20:46:51.000-04:00
diff --git a/src/local.js b/src/local.js
@@ -144,9 +144,7 @@ export default ({
               args[i] = toValue(args[i]);
 
             const result = reflect(APPLY, v, toValue(this), args);
-            /* c8 ignore start */
-            return result instanceof Promise ? result.then(fromValue) : fromValue(result);
-            /* c8 ignore stop */
+            return result.then(fromValue);
           };
           wr = new WeakRef(fn);
           weakRefs.set(v, wr);
diff --git a/src/remote.js b/src/remote.js
@@ -318,6 +318,7 @@ export default ({
 
   let indirect = true, direct, reference;
 
+  const { apply } = Reflect;
   const { id, ref, unref } = heap();
   const weakRefs = new Map;
   const globalTarget = tv(OBJECT, null);
@@ -407,13 +408,13 @@ export default ({
      * @param  {...any} args
      * @returns
      */
-    reflect(method, uid, ...args) {
+    reflect: async (method, uid, ...args) => {
       switch (method) {
         case APPLY: {
           const [context, params] = args;
           for (let i = 0, length = params.length; i < length; i++)
             params[i] = fromValue(params[i]);
-          return toValue(Reflect.apply(ref(uid), fromValue(context), params));
+          return toValue(await apply(ref(uid), fromValue(context), params));
         }
         case UNREF: {
           released(ref(uid));
diff --git a/types/remote.d.ts b/types/remote.d.ts
@@ -48,7 +48,7 @@ declare function _default({ reflect, transform, released, buffer, timeout, }?: R
      * @param  {...any} args
      * @returns
      */
-    reflect(method: number, uid: number | null, ...args: any[]): any;
+    reflect: (method: number, uid: number | null, ...args: any[]) => Promise<any>;
 };
 export default _default;
 /**
