@akiroz/thalamus
Advanced tools
Comparing version 0.0.14 to 0.0.15
@@ -165,6 +165,9 @@ "use strict"; | ||
return __awaiter(this, void 0, void 0, function () { | ||
var err_1; | ||
var _this = this; | ||
return __generator(this, function (_a) { | ||
switch (_a.label) { | ||
case 0: return [4 /*yield*/, p_any_1["default"](this.servers.map(function (srv) { return srv.subscribe(_this.subDebounceState.topics); }))]; | ||
case 0: | ||
_a.trys.push([0, 2, , 3]); | ||
return [4 /*yield*/, p_any_1["default"](this.servers.map(function (srv) { return srv.subscribe(_this.subDebounceState.topics); }))]; | ||
case 1: | ||
@@ -174,3 +177,8 @@ _a.sent(); | ||
this.subDebounceState = null; | ||
return [2 /*return*/]; | ||
return [3 /*break*/, 3]; | ||
case 2: | ||
err_1 = _a.sent(); | ||
this.subDebounceState.event.emit("err", err_1); | ||
return [3 /*break*/, 3]; | ||
case 3: return [2 /*return*/]; | ||
} | ||
@@ -203,3 +211,6 @@ }); | ||
event: event_1, | ||
promise: new Promise(function (r) { return event_1.once("sub", r); }), | ||
promise: new Promise(function (rsov, rjct) { | ||
event_1.once("sub", rsov); | ||
event_1.once("err", rjct); | ||
}), | ||
timeout: setTimeout(function () { return _this.sendSubscribe(); }, this.subDebounceWindow) | ||
@@ -206,0 +217,0 @@ }; |
{ | ||
"name": "@akiroz/thalamus", | ||
"version": "0.0.14", | ||
"version": "0.0.15", | ||
"repository": "github:akiroz/Thalamus", | ||
@@ -5,0 +5,0 @@ "main": "dist/thalamus.js", |
17149
293