Skip to content
Snippets Groups Projects
Unverified Commit 9d077bc2 authored by Guilherme Gazzo's avatar Guilherme Gazzo Committed by GitHub
Browse files

Regression: watchByRegex without Fibers (#23529)

parent ff757b99
No related branches found
No related tags found
No related merge requests found
...@@ -7,8 +7,8 @@ import { settings } from './functions/settings'; ...@@ -7,8 +7,8 @@ import { settings } from './functions/settings';
const getProcessingTimeInMS = (time: [number, number]): number => time[0] * 1000 + time[1] / 1e6; const getProcessingTimeInMS = (time: [number, number]): number => time[0] * 1000 + time[1] / 1e6;
settings.watch = use(settings.watch, (context, next) => { settings.watch = use(settings.watch, (context, next) => {
const [_id, callback] = context; const [_id, callback, ...args] = context;
return next(_id, Meteor.bindEnvironment(callback)); return next(_id, Meteor.bindEnvironment(callback), ...args);
}); });
if (process.env.DEBUG_SETTINGS === 'true') { if (process.env.DEBUG_SETTINGS === 'true') {
...@@ -23,23 +23,38 @@ if (process.env.DEBUG_SETTINGS === 'true') { ...@@ -23,23 +23,38 @@ if (process.env.DEBUG_SETTINGS === 'true') {
}); });
} }
settings.watchMultiple = use(settings.watchMultiple, (context, next) => { settings.watchMultiple = use(settings.watchMultiple, (context, next) => {
const [_id, callback] = context; const [_id, callback, ...args] = context;
return next(_id, Meteor.bindEnvironment(callback)); return next(_id, Meteor.bindEnvironment(callback), ...args);
}); });
settings.watchOnce = use(settings.watchOnce, (context, next) => { settings.watchOnce = use(settings.watchOnce, (context, next) => {
const [_id, callback] = context; const [_id, callback, ...args] = context;
return next(_id, Meteor.bindEnvironment(callback)); return next(_id, Meteor.bindEnvironment(callback), ...args);
});
settings.watchByRegex = use(settings.watchByRegex, (context, next) => {
const [_id, callback, ...args] = context;
return next(_id, Meteor.bindEnvironment(callback), ...args);
}); });
settings.change = use(settings.change, (context, next) => { settings.change = use(settings.change, (context, next) => {
const [_id, callback] = context; const [_id, callback, ...args] = context;
return next(_id, Meteor.bindEnvironment(callback)); return next(_id, Meteor.bindEnvironment(callback), ...args);
}); });
settings.changeMultiple = use(settings.changeMultiple, (context, next) => { settings.changeMultiple = use(settings.changeMultiple, (context, next) => {
const [_id, callback] = context; const [_id, callback, ...args] = context;
return next(_id, Meteor.bindEnvironment(callback)); return next(_id, Meteor.bindEnvironment(callback), ...args);
}); });
settings.changeOnce = use(settings.changeOnce, (context, next) => { settings.changeOnce = use(settings.changeOnce, (context, next) => {
const [_id, callback] = context; const [_id, callback, ...args] = context;
return next(_id, Meteor.bindEnvironment(callback)); return next(_id, Meteor.bindEnvironment(callback), ...args);
});
settings.changeByRegex = use(settings.changeByRegex, (context, next) => {
const [_id, callback, ...args] = context;
return next(_id, Meteor.bindEnvironment(callback), ...args);
});
settings.onReady = use(settings.onReady, (context, next) => {
const [callback, ...args] = context;
return next(Meteor.bindEnvironment(callback), ...args);
}); });
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment