Simple and modern async event emitter
It works in Node.js and the browser (using a bundler).
Highlights
- Async-first — listeners are deferred to the next microtask, keeping your code non-blocking
- TypeScript support with strongly typed events
- Async iteration and
for await...ofsupport - Lifecycle hooks (
init/deinit) for lazy resource setup and teardown AbortSignalsupport for cancellationSymbol.dispose/Symbol.asyncDisposesupport for automatic cleanup- Meta events for observing listener changes
- Debug mode with customizable logging
- Zero dependencies
Emitting events asynchronously is important for production code where you want the least amount of synchronous operations. Since JavaScript is single-threaded, no other code can run while doing synchronous operations. For Node.js, that means it will block other requests, defeating the strength of the platform, which is scalability through async. In the browser, a synchronous operation could potentially cause lags and block user interaction.
npm install emitteryimport Emittery from 'emittery';
const emitter = new Emittery();
emitter.on('🦄', ({data}) => {
console.log(data);
});
const myUnicorn = Symbol('🦄');
emitter.on(myUnicorn, ({data}) => {
console.log(`Unicorns love ${data}`);
});
emitter.emit('🦄', '🌈'); // Will trigger printing '🌈'
emitter.emit(myUnicorn, '🦋'); // Will trigger printing 'Unicorns love 🦋'Emittery accepts strings, symbols, and numbers as event names.
Symbol event names are preferred given that they can be used to avoid name collisions when your classes are extended, especially for internal events.
Toggle debug mode for all instances.
Default: true if the DEBUG environment variable is set to emittery or *, otherwise false.
Example:
import Emittery from 'emittery';
Emittery.isDebugEnabled = true;
const emitter1 = new Emittery({debug: {name: 'myEmitter1'}});
const emitter2 = new Emittery({debug: {name: 'myEmitter2'}});
emitter1.on('test', () => {
// …
});
emitter2.on('otherTest', () => {
// …
});
emitter1.emit('test');
//=> [16:43:20.417][emittery:subscribe][myEmitter1] Event Name: test
// data: undefined
emitter2.emit('otherTest');
//=> [16:43:20.417][emittery:subscribe][myEmitter2] Event Name: otherTest
// data: undefinedCreate a new instance of Emittery.
Type: object
Configure the new instance of Emittery.
Type: object
Configure the debugging options for this instance.
Type: string
Default: undefined
Define a name for the instance of Emittery to use when outputting debug data.
Example:
import Emittery from 'emittery';
Emittery.isDebugEnabled = true;
const emitter = new Emittery({debug: {name: 'myEmitter'}});
emitter.on('test', () => {
// …
});
emitter.emit('test');
//=> [16:43:20.417][emittery:subscribe][myEmitter] Event Name: test
// data: undefinedType: boolean
Default: false
Toggle debug logging just for this instance.
Example:
import Emittery from 'emittery';
const emitter1 = new Emittery({debug: {name: 'emitter1', enabled: true}});
const emitter2 = new Emittery({debug: {name: 'emitter2'}});
emitter1.on('test', () => {
// …
});
emitter2.on('test', () => {
// …
});
emitter1.emit('test');
//=> [16:43:20.417][emittery:subscribe][emitter1] Event Name: test
// data: undefined
emitter2.emit('test');Type: Function(string, string, EventName?, Record<string, any>?) => void
Default:
(type, debugName, eventName, eventData) => {
try {
eventData = JSON.stringify(eventData);
} catch {
eventData = `Object with the following keys failed to stringify: ${Object.keys(eventData).join(',')}`;
}
if (typeof eventName === 'symbol' || typeof eventName === 'number') {
eventName = eventName.toString();
}
const currentTime = new Date();
const logTime = `${currentTime.getHours()}:${currentTime.getMinutes()}:${currentTime.getSeconds()}.${currentTime.getMilliseconds()}`;
console.log(`[${logTime}][emittery:${type}][${debugName}] Event Name: ${eventName}\n\tdata: ${eventData}`);
}Function that handles debug data.
Example:
import Emittery from 'emittery';
const myLogger = (type, debugName, eventName, eventData) => {
console.log(`[${type}]: ${eventName}`);
};
const emitter = new Emittery({
debug: {
name: 'myEmitter',
enabled: true,
logger: myLogger
}
});
emitter.on('test', () => {
// …
});
emitter.emit('test');
//=> [subscribe]: testSubscribe to one or more events.
Returns an unsubscribe method (which is also Disposable, so it can be used with using).
Using the same listener multiple times for the same event will result in only one method call per emitted event.
import Emittery from 'emittery';
const emitter = new Emittery();
emitter.on('🦄', ({data}) => {
console.log(data);
});
emitter.on(['🦄', '🐶'], ({name, data}) => {
console.log(name, data);
});
emitter.emit('🦄', '🌈'); // log => '🌈' and '🦄 🌈'
emitter.emit('🐶', '🍖'); // log => '🐶 🍖'You can pass an abort signal to unsubscribe too:
import Emittery from 'emittery';
const emitter = new Emittery();
const abortController = new AbortController();
emitter.on('🐗', ({data}) => {
console.log(data);
}, {signal: abortController.signal});
abortController.abort();
emitter.emit('🐗', '🍞'); // Nothing happensOr use using for automatic cleanup when leaving scope:
import Emittery from 'emittery';
const emitter = new Emittery();
{
using off = emitter.on('🦄', ({data}) => {
console.log(data);
});
await emitter.emit('🦄', '🌈'); // Logs '🌈'
}
await emitter.emit('🦄', '🌈'); // Nothing happensEmittery exports some symbols which represent "meta" events that can be passed to Emittery.on and similar methods.
Emittery.listenerAdded- Fires when an event listener was added.Emittery.listenerRemoved- Fires when an event listener was removed.
import Emittery from 'emittery';
const emitter = new Emittery();
emitter.on(Emittery.listenerAdded, ({data: {listener, eventName}}) => {
console.log(listener);
//=> ({data}) => {}
console.log(eventName);
//=> '🦄'
});
emitter.on('🦄', ({data}) => {
// Handle data
});listener- The listener that was added.eventName- The name of the event that was added or removed if.on()or.off()was used, orundefinedif.onAny()or.offAny()was used.
Only events that are not of this type are able to trigger these events.
Remove one or more event subscriptions.
import Emittery from 'emittery';
const emitter = new Emittery();
const listener = ({data}) => {
console.log(data);
};
emitter.on(['🦄', '🐶', '🦊'], listener);
await emitter.emit('🦄', 'a');
await emitter.emit('🐶', 'b');
await emitter.emit('🦊', 'c');
emitter.off('🦄', listener);
emitter.off(['🐶', '🦊'], listener);
await emitter.emit('🦄', 'a'); // Nothing happens
await emitter.emit('🐶', 'b'); // Nothing happens
await emitter.emit('🦊', 'c'); // Nothing happensSubscribe to one or more events only once. It will be unsubscribed after the first event that matches the predicate (if provided).
The second argument can be a predicate function or an options object with predicate and/or signal.
Returns a promise for the event data when eventName is emitted and predicate matches (if provided). This promise is extended with an off method.
import Emittery from 'emittery';
const emitter = new Emittery();
const {data} = await emitter.once('🦄');
console.log(data);
//=> '🌈'// With multiple event names
const {name, data} = await emitter.once(['🦄', '🐶']);
console.log(name, data);// With predicate
const event = await emitter.once('data', ({data}) => data.ok === true);
console.log(event.data);
//=> {ok: true, value: 42}You can pass an abort signal to cancel the subscription. If the signal is aborted before the event fires, the returned promise rejects with the signal's reason. This is useful for timeouts:
import Emittery from 'emittery';
const emitter = new Emittery();
// Reject if 'ready' doesn't fire within 5 seconds
await emitter.once('ready', {signal: AbortSignal.timeout(5000)});The returned promise has an off method to cancel the subscription without rejecting:
import Emittery from 'emittery';
const emitter = new Emittery();
const promise = emitter.once('🦄');
// Cancel the subscription (the promise will never resolve)
promise.off();Get an async iterator which buffers data each time an event is emitted.
Call return() on the iterator to remove the subscription. You can also pass an abort signal to cancel the subscription externally, or use await using for automatic cleanup.
import Emittery from 'emittery';
const emitter = new Emittery();
for await (const {data} of emitter.events('🦄')) {
console.log(data);
if (data === '🌈2') {
break; // Revoke the subscription when we see the value '🌈2'.
}
}It accepts multiple event names:
import Emittery from 'emittery';
const emitter = new Emittery();
for await (const {name, data} of emitter.events(['🦄', '🦊'])) {
console.log(name, data);
}You can use await using for automatic cleanup when leaving scope:
import Emittery from 'emittery';
const emitter = new Emittery();
{
await using iterator = emitter.events('🦄');
for await (const {data} of iterator) {
console.log(data);
}
} // Subscription is automatically revokedSince Emittery requires Node.js 22+, you can use the built-in async iterator helpers to transform events:
import Emittery from 'emittery';
const emitter = new Emittery();
for await (const {data} of emitter.events('🦄').filter(event => event.data > 3).take(5)) {
console.log(data);
}Trigger an event asynchronously, optionally with some data. Listeners are called in the order they were added, but executed concurrently.
Returns a promise that resolves when all the event listeners are done. Done meaning executed if synchronous or resolved when an async/promise-returning function. You usually wouldn't want to wait for this, but you could for example catch possible errors. If any listeners throw/reject, the returned promise rejects with an AggregateError — all listener errors are collected in error.errors, so no errors are silently lost. All listeners always run to completion, even if some throw or reject.
Same as above, but it waits for each listener to resolve before triggering the next one. This can be useful if your events depend on each other. Although ideally they should not. Prefer emit() whenever possible.
If any of the listeners throw/reject, the returned promise will be rejected with the error and the remaining listeners will not be called.
import Emittery from 'emittery';
const emitter = new Emittery();
emitter.on('🦄', async () => {
console.log('listener 1 start');
await new Promise(resolve => setTimeout(resolve, 100));
console.log('listener 1 done');
});
emitter.on('🦄', () => {
console.log('listener 2'); // Only runs after listener 1 is done
});
await emitter.emitSerial('🦄');Subscribe to be notified about any event.
Returns a method to unsubscribe (which is also Disposable). Abort signal is respected too.
import Emittery from 'emittery';
const emitter = new Emittery();
const off = emitter.onAny(({name, data}) => {
console.log(name, data);
});
emitter.emit('🦄', '🌈'); // log => '🦄 🌈'
emitter.emit('🐶', '🍖'); // log => '🐶 🍖'
off();Remove an onAny subscription.
import Emittery from 'emittery';
const emitter = new Emittery();
const listener = ({name, data}) => {
console.log(name, data);
};
emitter.onAny(listener);
emitter.emit('🦄', '🌈'); // log => '🦄 🌈'
emitter.offAny(listener);
emitter.emit('🦄', '🌈'); // Nothing happensGet an async iterator which buffers an event object each time an event is emitted.
Call return() on the iterator to remove the subscription. You can also pass an abort signal to cancel the subscription externally, or use await using for automatic cleanup.
import Emittery from 'emittery';
const emitter = new Emittery();
for await (const {name, data} of emitter.anyEvent()) {
console.log(name, data);
}You can use await using for automatic cleanup when leaving scope:
import Emittery from 'emittery';
const emitter = new Emittery();
{
await using iterator = emitter.anyEvent();
for await (const {name, data} of iterator) {
console.log(name, data);
}
} // Subscription is automatically revokedClear all event listeners on the instance.
If eventNames is given, only the listeners for those events are cleared. Accepts a single event name or an array.
import Emittery from 'emittery';
const emitter = new Emittery();
emitter.on('🦄', listener);
emitter.on('🐶', listener);
emitter.on('🦊', listener);
// Clear a single event
emitter.clearListeners('🦄');
// Clear multiple events
emitter.clearListeners(['🐶', '🦊']);
// Clear all events
emitter.clearListeners();Register a function to be called when the first .on() listener subscribes to eventName. The initFn can optionally return a cleanup (deinit) function, which is called when the last .on() listener unsubscribes (or when clearListeners() removes all listeners for that event).
If .on() listeners already exist when init() is called, initFn is called immediately.
Returns an unsubscribe function (which is also Disposable). Calling it removes the init/deinit hooks, and if the init is currently active, it calls deinit immediately.
Note
Lifecycle hooks only apply to .on() listeners. Subscriptions via .events() async iterators do not trigger the init or deinit functions.
import Emittery from 'emittery';
const emitter = new Emittery();
emitter.init('mouse', () => {
terminal.grabInput({mouse: 'button'});
terminal.on('mouse', (name, data) => {
emitter.emit('mouse', data);
});
// Optional: return cleanup (deinit) function
return () => {
terminal.releaseInput();
};
});
// Init is called when the first listener subscribes
const off = emitter.on('mouse', handler);
// Adding more listeners does not call init again
emitter.on('mouse', anotherHandler);
// Removing one listener does not call deinit yet
off();
// Deinit is called when the last listener unsubscribes
emitter.off('mouse', anotherHandler);You can use using for automatic cleanup of the init/deinit hooks:
import Emittery from 'emittery';
const emitter = new Emittery();
{
using removeInit = emitter.init('mouse', () => {
startListening();
return () => stopListening();
});
} // init/deinit hooks are automatically removedThe number of listeners for the eventNames or all events if not specified.
import Emittery from 'emittery';
const emitter = new Emittery();
emitter.on('🦄', listener);
emitter.on('🐶', listener);
emitter.listenerCount('🦄'); // 1
emitter.listenerCount(); // 2Bind the given methodNames, or all Emittery methods if methodNames is not defined, into the target object.
import Emittery from 'emittery';
const object = {};
new Emittery().bindMethods(object);
object.emit('event');The default Emittery class has generic types that can be provided by TypeScript users to strongly type the list of events and the data passed to their event listeners.
import Emittery from 'emittery';
const emitter = new Emittery<
// Pass `{[eventName]: undefined | <eventArg>}` as the first type argument for events that pass data to their listeners.
// A value of `undefined` in this map means the event listeners should expect no data, and a type other than `undefined` means the listeners will receive one argument of that type.
{
open: string,
close: undefined
}
>();
// Typechecks just fine because the data type for the `open` event is `string`.
emitter.emit('open', 'foo\n');
// Typechecks just fine because `close` is present but points to undefined in the event data type map.
emitter.emit('close');
// TS compilation error because `1` isn't assignable to `string`.
emitter.emit('open', 1);
// TS compilation error because `other` isn't defined in the event data type map.
emitter.emit('other');A decorator which mixins Emittery as property emitteryPropertyName and methodNames, or all Emittery methods if methodNames is not defined, into the target class.
import Emittery from 'emittery';
@Emittery.mixin('emittery')
class MyClass {}
const instance = new MyClass();
instance.emit('event');Listeners are not invoked for events emitted before the listener was added. Removing a listener will prevent that listener from being invoked, even if events are in the process of being (asynchronously!) emitted. This also applies to .clearListeners(), which removes all listeners. Listeners will be called in the order they were added. So-called any listeners are called after event-specific listeners.
Listeners always fire asynchronously — they are deferred to the next microtask, so any synchronous code after an unawaited emit() call runs first. If ordering matters, use await emit().
Note that when using .emitSerial(), a slow listener will delay invocation of subsequent listeners. It's possible for newer events to overtake older ones.
Emittery can collect and log debug information.
To enable this feature set the DEBUG environment variable to 'emittery' or '*'. Additionally you can set the static isDebugEnabled variable to true on the Emittery class, or myEmitter.debug.enabled on an instance of it for debugging a single instance.
See API for more details on how debugging works.
There are many things to not like about EventEmitter: its huge API surface, synchronous event emitting, magic error event, flawed memory leak detection. Emittery has none of that.
Mostly backwards compatibility reasons. The Node.js team can't break the whole ecosystem.
It also allows silly code like this:
let unicorn = false;
emitter.on('🦄', () => {
unicorn = true;
});
emitter.emit('🦄');
console.log(unicorn);
//=> trueBut I would argue doing that shows a deeper lack of Node.js and async comprehension and is not something we should optimize for. The benefit of async emitting is much greater.
No. Async emission is Emittery's core design principle. If you need synchronous event emission (for example, proxying DOM events like React's onChange), use a synchronous event emitter.
No, just use destructuring:
emitter.on('🦄', ({data: [foo, bar]}) => {
console.log(foo, bar);
});
emitter.emit('🦄', [foo, bar]);- p-event - Promisify an event by waiting for it to be emitted
