mirror of
https://github.com/appy-one/acebase.git
synced 2026-05-25 22:01:21 -06:00
chore: build
This commit is contained in:
parent
1b573a3309
commit
612d1bce61
2 changed files with 10 additions and 24 deletions
32
dist/browser.js
vendored
32
dist/browser.js
vendored
|
|
@ -3941,27 +3941,18 @@ class SimpleEventEmitter {
|
|||
return this;
|
||||
}
|
||||
once(event, callback) {
|
||||
let resolve;
|
||||
const promise = new Promise(rs => {
|
||||
if (!callback) {
|
||||
// No callback used, promise only
|
||||
resolve = rs;
|
||||
return new Promise(resolve => {
|
||||
const ourCallback = (data) => {
|
||||
resolve(data);
|
||||
callback === null || callback === void 0 ? void 0 : callback(data);
|
||||
};
|
||||
if (this._oneTimeEvents.has(event)) {
|
||||
runCallback(ourCallback, this._oneTimeEvents.get(event));
|
||||
}
|
||||
else {
|
||||
// Callback used, maybe also returned promise
|
||||
resolve = (data) => {
|
||||
rs(data); // resolve promise
|
||||
callback(data); // trigger callback
|
||||
};
|
||||
this._subscriptions.push({ event, callback: ourCallback, once: true });
|
||||
}
|
||||
});
|
||||
if (this._oneTimeEvents.has(event)) {
|
||||
runCallback(resolve, this._oneTimeEvents.get(event));
|
||||
}
|
||||
else {
|
||||
this._subscriptions.push({ event, callback: resolve, once: true });
|
||||
}
|
||||
return promise;
|
||||
}
|
||||
emit(event, data) {
|
||||
if (this._oneTimeEvents.has(event)) {
|
||||
|
|
@ -3972,12 +3963,7 @@ class SimpleEventEmitter {
|
|||
if (s.event !== event) {
|
||||
continue;
|
||||
}
|
||||
try {
|
||||
s.callback(data);
|
||||
}
|
||||
catch (err) {
|
||||
console.error('Error in subscription callback', err);
|
||||
}
|
||||
runCallback(s.callback, data);
|
||||
if (s.once) {
|
||||
this._subscriptions.splice(i, 1);
|
||||
i--;
|
||||
|
|
|
|||
2
dist/browser.min.js
vendored
2
dist/browser.min.js
vendored
File diff suppressed because one or more lines are too long
Loading…
Add table
Add a link
Reference in a new issue