github/meteor
1
1
Fork 0
mirror of https://github.com/meteor/meteor.git synced 2026-05-02 03:01:46 -04:00
Code Issues Packages Projects Releases Wiki Activity

use bindEnvironment in forkJoin

Browse Source
This commit is contained in:
David Glasser
2014-11-05 17:53:16 -08:00
parent d072249bdf
commit 30499812e7
1 changed files with 12 additions and 21 deletions
Download Patch File Download Diff File Expand all files Collapse all files

33
tools/buildmessage.js
View File

@@ -499,33 +499,24 @@ var forkJoin = function (options, iterable, fn) {
options.forkJoin = true;
enterJob(options, function () {
var job = currentJob.get();
var messageSet = currentMessageSet.get();
var progress = currentProgress.get();
var nestingLevel = currentNestingLevel.get();
var parallel = (options.parallel !== undefined) ? options.parallel : true;
if (parallel) {
var runOne = fiberHelpers.bindEnvironment(function (fut, fnArguments) {
try {
var result = enterJob({title: (options.title || '') + ' child'}, function () {
return fn.apply(null, fnArguments);
});
fut['return'](result);
} catch (e) {
fut['throw'](e);
}
});
_.each(iterable, function (/*arguments*/) {
var fut = new Future();
var fnArguments = arguments;
Fiber(function () {
currentNestingLevel.withValue(nestingLevel, function() {
currentProgress.withValue(progress, function () {
currentMessageSet.withValue(messageSet, function () {
currentJob.withValue(job, function () {
try {
var result = enterJob({title: (options.title || '') + ' child'}, function () {
return fn.apply(null, fnArguments);
});
fut['return'](result);
} catch (e) {
fut['throw'](e);
}
});
});
});
});
runOne(fut, fnArguments);
}).run();
futures.push(fut);
});