feat: add call noReply option. closes #10

Author: mikuso

README.md

@@ -532,6 +532,7 @@ If the invocation of the `handler` rejects or throws, an error will be passed to
 * `options` {Object}
   * `callTimeoutMs` {Number} - Milliseconds before unanswered call is rejected. Defaults to the same value as the option passed to the client/server constructor.
   * `signal` {AbortSignal} - `AbortSignal` to abort the call.
+  * `noReply` {Boolean} - Send call without expecting a response, resolving immediately with `undefined`. If a response is received, a `badMessage` event will be emitted instead. Defaults to `false`.
 
 Calls a remote method. Returns a `Promise` which either:
 * resolves to the value returned by the remote handler.

lib/client.js

@@ -262,6 +262,7 @@ class RPCClient extends EventEmitter {
      * @param {Object} options - Call options
      * @param {number} options.callTimeoutMs - Call timeout (in milliseconds)
      * @param {AbortSignal} options.signal - AbortSignal to cancel the call.
+     * @param {boolean} options.noReply - If set to true, the call will return immediately.
      * @returns Promise<*> - Response value from the remote handler.
      */
     async call(method, params, options = {}) {
@@ -289,50 +290,57 @@ class RPCClient extends EventEmitter {
         }
 
         const pendingCall = {msgId, method, params};
-        const timeoutAc = new AbortController();
 
-        const cleanup = () => {
-            if (pendingCall.timeout) {
-                timeoutAc.abort();
+        if (!options.noReply) {
+            const timeoutAc = new AbortController();
+
+            const cleanup = () => {
+                if (pendingCall.timeout) {
+                    timeoutAc.abort();
+                }
+                this._pendingCalls.delete(msgId);
+            };
+            
+            pendingCall.abort = (reason) => {
+                const err = Error(reason);
+                err.name = "AbortError";
+                pendingCall.reject(err);
+            };
+
+            if (options.signal) {
+                once(options.signal, 'abort').then(() => {
+                    pendingCall.abort(options.signal.reason);
+                });
             }
-            this._pendingCalls.delete(msgId);
-        };
-        
-        pendingCall.abort = (reason) => {
-            const err = Error(reason);
-            err.name = "AbortError";
-            pendingCall.reject(err);
-        };
 
-        if (options.signal) {
-            once(options.signal, 'abort').then(() => {
-                pendingCall.abort(options.signal.reason);
+            pendingCall.promise = new Promise((resolve, reject) => {
+                pendingCall.resolve = (...args) => {
+                    cleanup();
+                    resolve(...args);
+                };
+                pendingCall.reject = (...args) => {
+                    cleanup();
+                    reject(...args);
+                };
             });
-        }
 
-        pendingCall.promise = new Promise((resolve, reject) => {
-            pendingCall.resolve = (...args) => {
-                cleanup();
-                resolve(...args);
-            };
-            pendingCall.reject = (...args) => {
-                cleanup();
-                reject(...args);
-            };
-        });
+            if (timeoutMs && timeoutMs > 0 && timeoutMs < Infinity) {
+                const timeoutError = new TimeoutError("Call timeout");
+                pendingCall.timeout = setTimeout(timeoutMs, null, {signal: timeoutAc.signal}).then(() => {
+                    pendingCall.reject(timeoutError);
+                }).catch(err=>{});
+            }
 
-        if (timeoutMs && timeoutMs > 0 && timeoutMs < Infinity) {
-            const timeoutError = new TimeoutError("Call timeout");
-            pendingCall.timeout = setTimeout(timeoutMs, null, {signal: timeoutAc.signal}).then(() => {
-                pendingCall.reject(timeoutError);
-            }).catch(err=>{});
+            this._pendingCalls.set(msgId, pendingCall);
         }
 
-        this._pendingCalls.set(msgId, pendingCall);
-
         this.emit('call', {outbound: true, payload});
         this.sendRaw(JSON.stringify(payload));
 
+        if (options.noReply) {
+            return;
+        }
+
         return await pendingCall.promise;
     }