coderofsalvation/xrfragment
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity

one reject now halts other promises

Browse source
This commit is contained in:
Leon van Kammen 2024-03-15 10:30:57 +00:00
parent c1f026f147
commit ac4a8d8c5a
1 changed files with 7 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

11
src/3rd/js/pubsub.js
View file

@ -44,13 +44,13 @@ xrf.emit = function(eventName, data){
return xrf.emit.promise(eventName,data) return xrf.emit.promise(eventName,data)
} }
xrf.emit.normal = function(eventName, data) { xrf.emit.normal = function(eventName, opts) {
if( !xrf._listeners ) xrf._listeners = [] if( !xrf._listeners ) xrf._listeners = []
var callbacks = xrf._listeners[eventName] var callbacks = xrf._listeners[eventName]
if (callbacks) { if (callbacks) {
for (var i = 0; i < callbacks.length; i++) { for (var i = 0; i < callbacks.length && !opts.halt; i++) {
try{ try{
callbacks[i](data); callbacks[i](opts);
}catch(e){ console.error(e) } }catch(e){ console.error(e) }
} }
} }
@ -67,7 +67,10 @@ xrf.emit.promise = function(e, opts){
let succesful = opts.promises.reduce( (a,b) => a+b ) let succesful = opts.promises.reduce( (a,b) => a+b )
if( succesful == opts.promises.length ) resolve(opts) if( succesful == opts.promises.length ) resolve(opts)
})(opts.promises.length-1), })(opts.promises.length-1),
reject: console.error reject: (reason) => {
opts.halt = true
console.warn(`'${e}' event rejected: ${reason}`)
}
} }
} }
xrf.emit.normal(e, opts) xrf.emit.normal(e, opts)