@matrixai/rpc - npm Package Compare versions

Comparing version 0.5.0 to 0.5.1

dist/RPCClient.js

@@ -241,9 +241,20 @@ "use strict";
         let rpcStream;
-        const streamFactoryProm = this.streamFactory({ signal, timer });
+        const streamFactoryProm = this.streamFactory({ signal, timer }).then((e) => ({ status: 'fulfilled', value: e }), (e) => ({ status: 'rejected', reason: e }));
         try {
-            rpcStream = await Promise.race([streamFactoryProm, abortRaceProm.p]);
+            const rpcStreamResult = await Promise.race([
+                streamFactoryProm,
+                abortRaceProm.p,
+            ]);
+            if (rpcStreamResult.status === 'rejected') {
+                throw rpcStreamResult.reason;
+            }
+            rpcStream = rpcStreamResult.value;
         }
         catch (e) {
             cleanUp();
-            void streamFactoryProm.then((stream) => stream.cancel(errors.ErrorRPCStreamEnded));
+            void streamFactoryProm.then((streamResult) => {
+                if (streamResult.status === 'fulfilled') {
+                    streamResult.value.cancel(errors.ErrorRPCStreamEnded);
+                }
+            });
             throw e;
@@ -250,0 +261,0 @@ }

package.json

 {
   "name": "@matrixai/rpc",
-  "version": "0.5.0",
+  "version": "0.5.1",
   "author": "Matrix AI",
@@ -5,0 +5,0 @@ "contributors": [

New alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Fixed alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

261866

increased by0.32%

Lines of code

3062

increased by0.36%

No dependency changes