Lines Matching refs:ee

12   const ee = new EventEmitter();
14     ee.emit('foo', 'bar');
17     ee.emit('bar', 24);
18     ee.emit('foo', 42);
21   const iterable = on(ee, 'foo');
34   assert.strictEqual(ee.listenerCount('foo'), 0);
35   assert.strictEqual(ee.listenerCount('error'), 0);
46   const ee = new EventEmitter();
49     ee.emit('error', _err);
52   const iterable = on(ee, 'foo');
70   const ee = new EventEmitter();
73     ee.emit('foo', 42);
74     ee.emit('error', _err);
77   const iterable = on(ee, 'foo');
91   assert.strictEqual(ee.listenerCount('foo'), 0);
92   assert.strictEqual(ee.listenerCount('error'), 0);
96   const ee = new EventEmitter();
100     ee.emit('foo', 42);
104     for await (const event of on(ee, 'foo')) {
112   assert.strictEqual(ee.listenerCount('foo'), 0);
113   assert.strictEqual(ee.listenerCount('error'), 0);
117   const ee = new EventEmitter();
118   const iterable = on(ee, 'foo');
121     ee.emit('foo', 'bar');
122     ee.emit('foo', 42);
150   const ee = new EventEmitter();
151   const iterable = on(ee, 'foo');
154     ee.emit('error', _err);
177   assert.strictEqual(ee.listeners('error').length, 0);
181   const ee = new EventEmitter();
182   const iterable = on(ee, 'foo');
185     ee.emit('foo', 'bar');
186     ee.emit('foo', 42); // lost in the queue
214   assert.strictEqual(ee.listenerCount('foo'), 0);
215   assert.strictEqual(ee.listenerCount('error'), 0);
257   const ee = new EventEmitter();
260     assert.throws(() => on(ee, 'foo', { signal }), {
264   assert.throws(() => on(ee, 'foo', { signal: abortedSignal }), {
283   const ee = new EventEmitter();
286   const i = setInterval(() => ee.emit('foo', 'foo'), 10);
289     for await (const f of on(ee, 'foo', { signal: ac.signal })) {
346   const ee = new EventEmitter();
349   const i = setInterval(() => ee.emit('foo', 'foo'), 1);
353     for await (const f of on(ee, 'foo', { signal: ac.signal })) {