cqrs-eventdenormalizer
Advanced tools
Comparing version 1.10.0 to 1.10.1
@@ -192,13 +192,27 @@ 'use strict'; | ||
var e = task.event, vbs = task.viewBuilders; | ||
async.each(vbs, function (vb, callback) { | ||
vb.denormalize(e, function (err) { | ||
--evtCount; | ||
if (err) { | ||
debug(err); | ||
errs.push(err); | ||
} | ||
callback(); | ||
}); | ||
}, function () { | ||
async.series([ | ||
function (clb) { | ||
var preEventExtender = self.dispatcher.tree.getPreEventExtender(self.dispatcher.getTargetInformation(e)); | ||
if (!preEventExtender) return clb(null); | ||
preEventExtender.extend(e, function (err, extEvt) { | ||
if (err) return clb(err); | ||
e = extEvt || e; | ||
clb(null); | ||
}); | ||
}, | ||
function (clb) { | ||
async.each(vbs, function (vb, callback) { | ||
vb.denormalize(e, function (err) { | ||
--evtCount; | ||
if (err) { | ||
debug(err); | ||
errs.push(err); | ||
} | ||
callback(); | ||
}); | ||
}, clb); | ||
} | ||
], function () { | ||
handleNext(); | ||
@@ -205,0 +219,0 @@ }); |
{ | ||
"author": "adrai", | ||
"name": "cqrs-eventdenormalizer", | ||
"version": "1.10.0", | ||
"version": "1.10.1", | ||
"private": false, | ||
@@ -6,0 +6,0 @@ "main": "index.js", |
@@ -0,1 +1,4 @@ | ||
## [v1.10.1](https://github.com/adrai/node-cqrs-eventdenormalizer/compare/v1.10.1...v1.10.1) | ||
- respect preEventExtenders in replayHandler | ||
## [v1.10.0](https://github.com/adrai/node-cqrs-eventdenormalizer/compare/v1.9.46...v1.10.0) | ||
@@ -2,0 +5,0 @@ - introduced preEventExtenders |
183433
4232