不要怂,就是干,撸起袖子干!

Commit db5e3d87 by Mick Hansen

feat(promises): adding extra sql propagation for Promise.all

1 parent 932fb177
Showing with 5 additions and 0 deletions
...@@ -41,10 +41,15 @@ Utils._.extend(SequelizePromise, Promise) ...@@ -41,10 +41,15 @@ Utils._.extend(SequelizePromise, Promise)
SequelizePromise.all = function(promises) { SequelizePromise.all = function(promises) {
var resolved = SequelizePromise.resolve(Promise.all(promises)); var resolved = SequelizePromise.resolve(Promise.all(promises));
// Propagate sql events
promises.forEach(function (promise) { promises.forEach(function (promise) {
promise.on('sql', function (sql) { promise.on('sql', function (sql) {
resolved.emit('sql', sql); resolved.emit('sql', sql);
}); });
promise.$sql.forEach(function (sql) {
resolved.emit('sql', sql);
});
}); });
return resolved; return resolved;
......
Markdown is supported
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!