@schemeless/event-store
Advanced tools
Comparing version 2.2.0-rc.4 to 2.2.0-rc.5
@@ -33,3 +33,3 @@ "use strict"; | ||
const subscription = observerQueue.processed$.subscribe(); | ||
observerQueue.queueInstance.drained$.subscribe(() => logger_1.logger.info(`replay all done`)); | ||
observerQueue.queueInstance.drained$.subscribe(() => logger_1.logger.debug(`observerQueue drained`)); | ||
try { | ||
@@ -43,2 +43,3 @@ for (var eventStoreIterator_1 = __asyncValues(eventStoreIterator), eventStoreIterator_1_1; eventStoreIterator_1_1 = yield eventStoreIterator_1.next(), !eventStoreIterator_1_1.done;) { | ||
yield acc; | ||
Object.assign(currentEvent, { created: new Date(currentEvent.created) }); | ||
const EventFlow = getEventFlow_1.getEventFlow(eventFlowMap)(currentEvent); | ||
@@ -65,4 +66,3 @@ logEvent_1.logEvent(currentEvent, '✅️️', 'Apply'); | ||
} | ||
subscription.unsubscribe(); | ||
}); | ||
exports.makeReplay = makeReplay; |
{ | ||
"name": "@schemeless/event-store", | ||
"version": "2.2.0-rc.4", | ||
"version": "2.2.0-rc.5", | ||
"typescript:main": "src/index.ts", | ||
@@ -33,3 +33,3 @@ "main": "dist/index.js", | ||
"devDependencies": { | ||
"@schemeless/event-store-adapter-dynamodb": "^2.2.0-rc.1", | ||
"@schemeless/event-store-adapter-dynamodb": "^2.2.0-rc.3", | ||
"@schemeless/event-store-adapter-typeorm": "^2.2.0-rc.1", | ||
@@ -53,3 +53,3 @@ "@types/better-queue": "^3.8.2", | ||
}, | ||
"gitHead": "a45b597f1b3ad8422705fd81e9b62ef66e788ce9" | ||
"gitHead": "b9b92b2cb912888a13965e968ce1a64bcf3f3421" | ||
} |
429741
80