@akiroz/thalamus - npm Package Compare versions

Comparing version 0.0.4 to 0.0.5

dist/thalamus.js

@@ -161,3 +161,9 @@ "use strict";
                         this.ee.addListener(topic, handler);
-                        return [4 /*yield*/, Promise.all(this.servers.map(function (serv) { return serv.subscribe(topic); }))];
+                        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);
+                                });
+                            }))];
                     case 1:
@@ -181,3 +187,9 @@ _a.sent();
                         }
-                        return [4 /*yield*/, Promise.all(this.servers.map(function (serv) { return serv.unsubscribe(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);
+                                });
+                            }))];
                     case 1:
@@ -184,0 +196,0 @@ _a.sent();

package.json

 {
     "name": "@akiroz/thalamus",
-    "version": "0.0.4",
+    "version": "0.0.5",
     "repository": "github:akiroz/Thalamus",
@@ -5,0 +5,0 @@ "main": "dist/thalamus.js",

README.md

@@ -22,7 +22,17 @@ # Thalamus
 
--   `constructor(serverOptList: MQTT.IClientOptions[])`
--   `async publish(topic: string, payload: Uint8Array)`
--   `async subscribe(topic: string, handler: SubHandler)`
--   `async unsubscribe(topic: string, handler?: SubHandler)`
--   `async call(topic: string, params: Param = {}, opt = defaultOptions): Promise<Result>`
--   `async register(topic: string, handler: (param, topic) => Result)`
+-  `constructor(serverOptList: MQTT.IClientOptions[])`
+
+- `thalamus.servers` List of MQTT client objects
+
+-  `async publish(topic: string, payload: Uint8Array)`
+-  `async subscribe(topic: string, handler: SubHandler)`
+-  `async unsubscribe(topic: string, handler?: SubHandler)`
+-  `async call(topic: string, params: Param = {}, opt = defaultOptions): Promise<Result>`
+-  `async register(topic: string, handler: (param, topic) => Result)`
+
+- `thalamus.ee.setMaxListeners(n)` Set maximum listeners for `subscribe` & `register`
+
+- `thalamus.on("connect", (i) => {})` server `i` connected (i = 0-based index)
+- `thalamus.on("close", (i) => {})` server `i` disconnected (i = 0-based index)
+- `thalamus.on("error", (err, i) => {})` server `i` error (i = 0-based index)
+

No alert changes

Improved metrics

Total package byte prevSize

14814

increased by7.45%

Lines of code

242

increased by5.22%

Number of lines in readme file

38

increased by35.71%

No dependency changes