f6fac6c4bc
Fix bin/publish: use correct .env path for rspade_system Fix bin/publish script: prevent grep exit code 1 from terminating script 🤖 Generated with [Claude Code](https://claude.com/claude-code) Co-Authored-By: Claude <noreply@anthropic.com>
51 lines
1.0 KiB
JavaScript
Executable File
51 lines
1.0 KiB
JavaScript
Executable File
/** @typedef {(...args: any) => void|Promise<void>} Handler */
|
|
|
|
const { concat } = require('lodash');
|
|
|
|
class Dispatcher {
|
|
/**
|
|
* Create a new Dispatcher instance.
|
|
*/
|
|
constructor() {
|
|
/** @type {Record<string, Handler[]>} */
|
|
this.events = {};
|
|
}
|
|
|
|
/**
|
|
* Listen for the given event.
|
|
*
|
|
* @param {string|string[]} events
|
|
* @param {Handler} handler
|
|
*/
|
|
listen(events, handler) {
|
|
events = concat([], events);
|
|
|
|
events.forEach(event => {
|
|
this.events[event] = (this.events[event] || []).concat(handler);
|
|
});
|
|
|
|
return this;
|
|
}
|
|
|
|
/**
|
|
* Trigger all handlers for the given event.
|
|
*
|
|
* @param {string} event
|
|
* @param {any} [data]
|
|
*/
|
|
async fire(event, data) {
|
|
if (!this.events[event]) return false;
|
|
|
|
return Promise.all(this.events[event].map(handler => handler(data)));
|
|
}
|
|
|
|
/**
|
|
* Fetch all registered event listeners.
|
|
*/
|
|
all() {
|
|
return this.events;
|
|
}
|
|
}
|
|
|
|
module.exports = Dispatcher;
|