Comparing version 2.1.1 to 2.1.2
{ | ||
"name": "rpcapi", | ||
"version": "2.1.1", | ||
"version": "2.1.2", | ||
"description": "Provides a struture for hosting RPC style APIs, supports both http and websocket access out of the box", | ||
@@ -5,0 +5,0 @@ "repository": { |
@@ -147,3 +147,3 @@ "use strict"; | ||
return __awaiter(this, void 0, void 0, function () { | ||
var endpoint, newEndpointConnection; | ||
var endpoint, newEndpointConnection, e_1; | ||
return __generator(this, function (_a) { | ||
@@ -163,8 +163,14 @@ switch (_a.label) { | ||
endpoint.accessKey = accessKey; | ||
//TODO: Clean up automatically if this fails? (we will currently leave a dead connection registered) | ||
_a.label = 1; | ||
case 1: | ||
_a.trys.push([1, 3, , 4]); | ||
return [4 /*yield*/, newEndpointConnection.endpoint.callConnect()]; | ||
case 1: | ||
//TODO: Clean up automatically if this fails? (we will currently leave a dead connection registered) | ||
case 2: | ||
_a.sent(); | ||
return [2 /*return*/, newEndpointConnection]; | ||
return [3 /*break*/, 4]; | ||
case 3: | ||
e_1 = _a.sent(); | ||
this.removeEndpointConnectionById(newEndpointConnection.endpointConnectionId); | ||
return [3 /*break*/, 4]; | ||
case 4: return [2 /*return*/, newEndpointConnection]; | ||
} | ||
@@ -171,0 +177,0 @@ }); |
Sorry, the diff of this file is not supported yet
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
489533
4663