fm453/nocobase
1
0
Fork 0
mirror of https://gitee.com/nocobase/nocobase.git synced 2025-05-09 15:39:24 +08:00
Code Issues Packages Projects Releases Wiki Activity

chore: api update

Browse Source
This commit is contained in:
gchust 2025-04-16 10:10:12 +08:00
parent caedd9720e
commit 84d8ccf83b
1 changed files with 14 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
packages/core/client/src/eventflow/event-bus.ts
View File

@ -63,10 +63,21 @@ export class EventBus {
return this.on(eventName, listener, { ...options, once: true }); return this.on(eventName, listener, { ...options, once: true });
} }
/**
* Removes an event listener or all listeners for eventName
*/
off(eventName: string | string[], listener?: EventListener): void {
if (Array.isArray(eventName)) {
eventName.forEach((name) => this.singleOff(name, listener));
} else {
this.singleOff(eventName, listener);
}
}
/** /**
* Removes an event listener or all listeners for an event * Removes an event listener or all listeners for an event
*/ */
off(eventName: string, listener?: EventListener): void { private singleOff(eventName: string, listener?: EventListener): void {
// Check if this is a wildcard pattern // Check if this is a wildcard pattern
const isWildcard = eventName.includes('*'); const isWildcard = eventName.includes('*');
const listenersMap = isWildcard ? this.patternListeners : this.listeners; const listenersMap = isWildcard ? this.patternListeners : this.listeners;
@ -152,7 +163,7 @@ export class EventBus {
listenersMap.get(eventName).push(registeredListener); listenersMap.get(eventName).push(registeredListener);
// Return unsubscribe function // Return unsubscribe function
return () => this.off(eventName, listener); return () => this.singleOff(eventName, listener);
} }
/** /**
@ -211,7 +222,7 @@ export class EventBus {
const result = listener(ctx); const result = listener(ctx);
// Handle async listeners // Handle async listeners
if (result instanceof Promise) { if (result instanceof Promise && options.blocking) {
await result; await result;
} }