onMessage(e) {
let me = this,
data = e.data,
action = data.action,
replyId = data.replyId,
promise;
if (!action) {
throw new Error('Message action is missing: ' + data.id);
}
if (action !== 'reply') {
try {
this['on' + Neo.capitalize(action)](data);
} catch(err) {
console.log('error', data, err, e);
this.reject(data.id, {
error : err.message
});
}
} else if (promise = action === 'reply' && me.promises[replyId]) {
if (data.reject) {
promise.reject(data.data);
} else {
promise.resolve(data.data);
}
delete me.promises[replyId];
}
}
the try check was from a time, where errors inside a worker did not get logged inside the chrome devtools.
it should be safe to just remove it:
onMessage(e) {
let me = this,
data = e.data,
action = data.action,
replyId = data.replyId,
promise;
if (!action) {
throw new Error('Message action is missing: ' + data.id);
}
if (action !== 'reply') {
me['on' + Neo.capitalize(action)](data);
} else if (promise = action === 'reply' && me.promises[replyId]) {
if (data.reject) {
promise.reject(data.data);
} else {
promise.resolve(data.data);
}
delete me.promises[replyId];
}
}
onMessage(e) { let me = this, data = e.data, action = data.action, replyId = data.replyId, promise; if (!action) { throw new Error('Message action is missing: ' + data.id); } if (action !== 'reply') { try { this['on' + Neo.capitalize(action)](data); } catch(err) { console.log('error', data, err, e); this.reject(data.id, { error : err.message }); } } else if (promise = action === 'reply' && me.promises[replyId]) { if (data.reject) { promise.reject(data.data); } else { promise.resolve(data.data); } delete me.promises[replyId]; } }the try check was from a time, where errors inside a worker did not get logged inside the chrome devtools.
it should be safe to just remove it:
onMessage(e) { let me = this, data = e.data, action = data.action, replyId = data.replyId, promise; if (!action) { throw new Error('Message action is missing: ' + data.id); } if (action !== 'reply') { me['on' + Neo.capitalize(action)](data); } else if (promise = action === 'reply' && me.promises[replyId]) { if (data.reject) { promise.reject(data.data); } else { promise.resolve(data.data); } delete me.promises[replyId]; } }