@serialized/serialized-client
Advanced tools
Comparing version 7.0.0 to 7.1.0
@@ -198,18 +198,3 @@ "use strict"; | ||
_a.trys.push([0, 2, , 3]); | ||
return [4 /*yield*/, this.aggregateClientConfig.retryStrategy.executeWithRetries(function () { return __awaiter(_this, void 0, void 0, function () { | ||
var e_1; | ||
return __generator(this, function (_a) { | ||
switch (_a.label) { | ||
case 0: | ||
_a.trys.push([0, 2, , 3]); | ||
return [4 /*yield*/, this.saveBulkInternal(batches, tenantId)]; | ||
case 1: return [2 /*return*/, _a.sent()]; | ||
case 2: | ||
e_1 = _a.sent(); | ||
console.log(e_1); | ||
return [3 /*break*/, 3]; | ||
case 3: return [2 /*return*/]; | ||
} | ||
}); | ||
}); })]; | ||
return [4 /*yield*/, this.aggregateClientConfig.retryStrategy.executeWithRetries(function () { return _this.saveBulkInternal(batches, tenantId); })]; | ||
case 1: return [2 /*return*/, _a.sent()]; | ||
@@ -243,10 +228,3 @@ case 2: | ||
_a.trys.push([1, 3, , 4]); | ||
return [4 /*yield*/, this.aggregateClientConfig.retryStrategy.executeWithRetries(function () { return __awaiter(_this, void 0, void 0, function () { | ||
return __generator(this, function (_a) { | ||
switch (_a.label) { | ||
case 0: return [4 /*yield*/, this.saveInternal({ aggregateId: aggregateId, events: eventsToSave, expectedVersion: 0 }, tenantId)]; | ||
case 1: return [2 /*return*/, _a.sent()]; | ||
} | ||
}); | ||
}); })]; | ||
return [4 /*yield*/, this.aggregateClientConfig.retryStrategy.executeWithRetries(function () { return _this.saveInternal({ aggregateId: aggregateId, events: eventsToSave, expectedVersion: 0 }, tenantId); })]; | ||
case 2: return [2 /*return*/, _a.sent()]; | ||
@@ -253,0 +231,0 @@ case 3: |
@@ -6,3 +6,3 @@ { | ||
"author": "Serialized", | ||
"version": "7.0.0", | ||
"version": "7.1.0", | ||
"main": "dist/index.js", | ||
@@ -9,0 +9,0 @@ "types": "dist/index.d.ts", |
119687
2548