Fix emitSerial() not delivering events to async iterators

Fixes #126

Author: sindresorhus

index.js

@@ -405,10 +405,12 @@ export default class Emittery {
 
 		this.logIfDebugEnabled('emitSerial', eventName, eventData);
 
+		enqueueProducers(this, eventName, eventData);
+
 		const listeners = getListeners(this, eventName) ?? new Set();
 		const anyListeners = anyMap.get(this);
 		const staticListeners = [...listeners];
-		const staticAnyListeners = [...anyListeners];
+		const staticAnyListeners = isMetaEvent(eventName) ? [] : [...anyListeners];
 
 		await resolvedPromise;
 		/* eslint-disable no-await-in-loop */

test/index.js

@@ -797,6 +797,48 @@ test('emitSerial() - calls listeners subscribed when emitSerial() was invoked',
 	t.deepEqual(calls, [1, 1, 2, 3, 2, 4, 5, 2, 4, 7, 6, 2, 4, 7, 6, 9, 2, 4, 7, 6, 9]);
 });
 
+test.serial('emitSerial() - delivers events to events() iterator', async t => {
+	const emitter = new Emittery();
+	const iterator = emitter.events('🦄');
+
+	await emitter.emitSerial('🦄', '🌈');
+	setTimeout(() => {
+		emitter.emitSerial('🦄', Promise.resolve('🌟'));
+	}, 10);
+
+	t.plan(3);
+	const expected = ['🌈', '🌟'];
+	for await (const data of iterator) {
+		t.deepEqual(data, expected.shift());
+		if (expected.length === 0) {
+			break;
+		}
+	}
+
+	t.deepEqual(await iterator.next(), {done: true});
+});
+
+test.serial('emitSerial() - delivers events to anyEvent() iterator', async t => {
+	const emitter = new Emittery();
+	const iterator = emitter.anyEvent();
+
+	await emitter.emitSerial('🦄', '🌈');
+	setTimeout(() => {
+		emitter.emitSerial('🦄', Promise.resolve('🌟'));
+	}, 10);
+
+	t.plan(3);
+	const expected = [['🦄', '🌈'], ['🦄', '🌟']];
+	for await (const data of iterator) {
+		t.deepEqual(data, expected.shift());
+		if (expected.length === 0) {
+			break;
+		}
+	}
+
+	t.deepEqual(await iterator.next(), {done: true});
+});
+
 test('emitSerial() - isDebug logs output', async t => {
 	const eventStore = [];