global listeners: .on('*', listener)

dist/events.js

@@ -7,24 +7,34 @@ const warnAboutMemoryLeak = (eventName, count) =>
   );
 
 export default class EventEmitter {
+  globalEventName = '*';
+
   constructor() {
     this.events = new Map();
     this.globalListeners = new Set();
     this.maxListenersCount = 10;
   }
 
+  isGlobalEvent(name) {
+    return name === this.globalEventName;
+  }
+
   getMaxListeners() {
     return this.maxListenersCount;
   }
 
   listenerCount(name) {
-    const event = this.events.get(name);
+    const event = this.isGlobalEvent(name)
+      ? this.globalListeners
+      : this.events.get(name);
     if (event) return event.size;
     return 0;
   }
 
   on(name, fn) {
-    const event = this.events.get(name);
+    const event = this.isGlobalEvent(name)
+      ? this.globalListeners
+      : this.events.get(name);
     if (event) {
       event.add(fn);
       const tooManyListeners = event.size > this.maxListenersCount;
@@ -34,16 +44,6 @@ export default class EventEmitter {
     }
   }
 
-  onAny(fn) {
-    const tooManyListeners = this.globalListeners.size > this.maxListenersCount;
-    if (tooManyListeners) warnAboutMemoryLeak('*', this.globalListeners.size);
-    this.globalListeners.add(fn);
-  }
-
-  clearGlobalListeners() {
-    this.globalListeners.clear();
-  }
-
   once(name, fn) {
     const dispose = (...args) => {
       this.remove(name, dispose);
@@ -53,26 +53,40 @@ export default class EventEmitter {
   }
 
   emit(name, ...args) {
+    if (this.isGlobalEvent(name))
+      throw new Error(
+        "Cannot emit '*'. Symbol is reserved for global listeners.",
+      );
     const event = this.events.get(name);
-    if (!event && !this.globalListeners.size) return;
-    for (const fn of event.values()) {
-      fn(...args);
+    if (event) {
+      for (const fn of event.values()) {
+        fn(...args);
+      }
     }
-    for (const fn of this.globalListeners.values()) {
-      fn(name, ...args);
+    if (this.globalListeners.size) {
+      for (const fn of this.globalListeners.values()) {
+        fn(name, ...args);
+      }
     }
   }
 
   remove(name, fn) {
-    const event = this.events.get(name);
+    const event = this.isGlobalEvent(name)
+      ? this.globalListeners
+      : this.events.get(name);
     if (!event) return;
     if (event.has(fn)) {
       event.delete(fn);
     }
   }
 
   clear(name) {
-    if (name) this.events.delete(name);
-    else this.events.clear();
+    if (!name) {
+      this.events.clear();
+      this.globalListeners.clear();
+      return;
+    }
+    if (this.isGlobalEvent(name)) this.globalListeners.clear();
+    else this.events.delete(name);
   }
 }

dist/metacom.js

@@ -158,7 +158,7 @@ export class Metacom extends EventEmitter {
       for (const methodName of methodNames) {
         methods[methodName] = request(methodName);
       }
-      methods.onAny((eventName, data) => {
+      methods.on('*', (eventName, data) => {
         const target = `${interfaceName}/${eventName}`;
         const packet = { event: ++this.eventId, [target]: data };
         this.send(JSON.stringify(packet));