@akiroz/thalamus - npm Package Compare versions

Comparing version 0.0.5 to 0.0.6

dist/thalamus.js

@@ -84,2 +84,3 @@ "use strict";
 var MQTT = __importStar(require("async-mqtt"));
+var promiseAny = __importStar(require("promise.any"));
 var RPC = __importStar(require("@akiroz/pubsub-rpc"));
@@ -162,9 +163,3 @@ var Thalamus = /** @class */ (function (_super) {
                         this.ee.addListener(topic, handler);
-                        return [4 /*yield*/, Promise.all(this.servers.map(function (serv) {
-                                return serv.subscribe(topic)["catch"](function (err) {
-                                    if (!serv.connected)
-                                        return null; // Ignore fail due to disconnect
-                                    return Promise.reject(err);
-                                });
-                            }))];
+                        return [4 /*yield*/, promiseAny(this.servers.map(function (srv) { return srv.subscribe(topic); }))];
                     case 1:
@@ -182,15 +177,7 @@ _a.sent();
                     case 0:
-                        if (handler) {
+                        if (handler)
                             this.ee.removeListener(topic, handler);
-                        }
-                        else {
+                        else
                             this.ee.removeAllListeners(topic);
-                        }
-                        return [4 /*yield*/, Promise.all(this.servers.map(function (serv) {
-                                return serv.unsubscribe(topic)["catch"](function (err) {
-                                    if (!serv.connected)
-                                        return null; // Ignore fail due to disconnect
-                                    return Promise.reject(err);
-                                });
-                            }))];
+                        return [4 /*yield*/, promiseAny(this.servers.map(function (srv) { return srv.unsubscribe(topic); }))];
                     case 1:
@@ -197,0 +184,0 @@ _a.sent();

package.json

 {
     "name": "@akiroz/thalamus",
-    "version": "0.0.5",
+    "version": "0.0.6",
     "repository": "github:akiroz/Thalamus",
@@ -30,4 +30,5 @@ "main": "dist/thalamus.js",
         "async-mqtt": "^2.6.1",
-        "events": "^3.1.0"
+        "events": "^3.1.0",
+        "promise.any": "^2.0.1"
     }
 }

No alert changes

Worsened metrics

Total package byte prevSize

14184

decreased by-4.25%

Dependency count

4

increased by33.33%

Lines of code

229

decreased by-5.37%

Dependency changes

• + Addedpromise.any@^2.0.1

• + Addedarray-buffer-byte-length@1.0.1(transitive)

• + Addedarray.prototype.map@1.0.7(transitive)

• + Addedarraybuffer.prototype.slice@1.0.3(transitive)

• + Addedavailable-typed-arrays@1.0.7(transitive)

• + Addedcall-bind@1.0.7(transitive)

• + Addeddata-view-buffer@1.0.1(transitive)

• + Addeddata-view-byte-length@1.0.1(transitive)

• + Addeddata-view-byte-offset@1.0.0(transitive)

• + Addeddefine-data-property@1.1.4(transitive)

• + Addeddefine-properties@1.2.1(transitive)

• + Addedes-abstract@1.23.3(transitive)

• + Addedes-aggregate-error@1.0.13(transitive)

• + Addedes-array-method-boxes-properly@1.0.0(transitive)

• + Addedes-define-property@1.0.0(transitive)

• + Addedes-errors@1.3.0(transitive)

• + Addedes-get-iterator@1.1.3(transitive)

• + Addedes-object-atoms@1.0.0(transitive)

• + Addedes-set-tostringtag@2.0.3(transitive)

• + Addedes-to-primitive@1.2.1(transitive)

• + Addedfor-each@0.3.3(transitive)

• + Addedfunction-bind@1.1.2(transitive)

• + Addedfunction.prototype.name@1.1.6(transitive)

• + Addedfunctions-have-names@1.2.3(transitive)

• + Addedget-intrinsic@1.2.4(transitive)

• + Addedget-symbol-description@1.0.2(transitive)

• + Addedglobalthis@1.0.4(transitive)

• + Addedgopd@1.0.1(transitive)

• + Addedhas-bigints@1.0.2(transitive)

• + Addedhas-property-descriptors@1.0.2(transitive)

• + Addedhas-proto@1.0.3(transitive)

• + Addedhas-symbols@1.0.3(transitive)

• + Addedhas-tostringtag@1.0.2(transitive)

• + Addedhasown@2.0.2(transitive)

• + Addedinternal-slot@1.0.7(transitive)

• + Addedis-arguments@1.1.1(transitive)

• + Addedis-array-buffer@3.0.4(transitive)

• + Addedis-bigint@1.0.4(transitive)

• + Addedis-boolean-object@1.1.2(transitive)

• + Addedis-callable@1.2.7(transitive)

• + Addedis-data-view@1.0.1(transitive)

• + Addedis-date-object@1.0.5(transitive)

• + Addedis-map@2.0.3(transitive)

• + Addedis-negative-zero@2.0.3(transitive)

• + Addedis-number-object@1.0.7(transitive)

• + Addedis-regex@1.1.4(transitive)

• + Addedis-set@2.0.3(transitive)

• + Addedis-shared-array-buffer@1.0.3(transitive)

• + Addedis-string@1.0.7(transitive)

• + Addedis-symbol@1.0.4(transitive)

• + Addedis-typed-array@1.1.13(transitive)

• + Addedis-weakref@1.0.2(transitive)

• + Addedisarray@2.0.5(transitive)

• + Addediterate-iterator@1.0.2(transitive)

• + Addediterate-value@1.0.2(transitive)

• + Addedobject-inspect@1.13.1(transitive)

• + Addedobject-keys@1.1.1(transitive)

• + Addedobject.assign@4.1.5(transitive)

• + Addedpossible-typed-array-names@1.0.0(transitive)

• + Addedpromise.any@2.0.6(transitive)

• + Addedregexp.prototype.flags@1.5.2(transitive)

• + Addedsafe-array-concat@1.1.2(transitive)

• + Addedsafe-regex-test@1.0.3(transitive)

• + Addedset-function-length@1.2.2(transitive)

• + Addedset-function-name@2.0.2(transitive)

• + Addedside-channel@1.0.6(transitive)

• + Addedstop-iteration-iterator@1.0.0(transitive)

• + Addedstring.prototype.trim@1.2.9(transitive)

• + Addedstring.prototype.trimend@1.0.8(transitive)

• + Addedstring.prototype.trimstart@1.0.8(transitive)

• + Addedtyped-array-buffer@1.0.2(transitive)

• + Addedtyped-array-byte-length@1.0.1(transitive)

• + Addedtyped-array-byte-offset@1.0.2(transitive)

• + Addedtyped-array-length@1.0.6(transitive)

• + Addedunbox-primitive@1.0.2(transitive)

• + Addedwhich-boxed-primitive@1.0.2(transitive)

• + Addedwhich-typed-array@1.1.15(transitive)