| FazBrowse GitHub Viewer | Trending | | Home |
| Tools: [Download Repo ZIP] [Original HTTPS Page] |
1 parent 96f93cc commit 159cf02
3 files changed
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
@@ -6,7 +6,7 @@ const timers = require('timers'); | |||
| 6 | 6 | const { promisify } = require('util'); | |
| 7 | 7 | const child_process = require('child_process'); | |
| 8 | 8 | ||
| 9 | - // TODO(benjamingr) - refactor to use getEventListeners when #35991 lands | ||
| 9 | + const { getEventListeners } = require('events'); | ||
| 10 | 10 | const { NodeEventTarget } = require('internal/event_target'); | |
| 11 | 11 | ||
| 12 | 12 | const timerPromises = require('timers/promises'); | |
@@ -60,7 +60,7 @@ process.on('multipleResolves', common.mustNotCall()); | |||
| 60 | 60 | const signal = new NodeEventTarget(); | |
| 61 | 61 | signal.aborted = false; | |
| 62 | 62 | setPromiseImmediate(0, { signal }).finally(common.mustCall(() => { | |
| 63 | - assert.strictEqual(signal.listenerCount('abort'), 0); | ||
| 63 | + assert.strictEqual(getEventListeners(signal, 'abort').length, 0); | ||
| 64 | 64 | })); | |
| 65 | 65 | } | |
| 66 | 66 | ||
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
@@ -6,7 +6,7 @@ const timers = require('timers'); | |||
| 6 | 6 | const { promisify } = require('util'); | |
| 7 | 7 | const child_process = require('child_process'); | |
| 8 | 8 | ||
| 9 | - // TODO(benjamingr) - refactor to use getEventListeners when #35991 lands | ||
| 9 | + const { getEventListeners } = require('events'); | ||
| 10 | 10 | const { NodeEventTarget } = require('internal/event_target'); | |
| 11 | 11 | ||
| 12 | 12 | const timerPromises = require('timers/promises'); | |
@@ -122,10 +122,10 @@ process.on('multipleResolves', common.mustNotCall()); | |||
| 122 | 122 | signal.aborted = false; | |
| 123 | 123 | const iterator = setInterval(1, undefined, { signal }); | |
| 124 | 124 | iterator.next().then(common.mustCall(() => { | |
| 125 | - assert.strictEqual(signal.listenerCount('abort'), 1); | ||
| 125 | + assert.strictEqual(getEventListeners(signal, 'abort').length, 1); | ||
| 126 | 126 | iterator.return(); | |
| 127 | 127 | })).finally(common.mustCall(() => { | |
| 128 | - assert.strictEqual(signal.listenerCount('abort'), 0); | ||
| 128 | + assert.strictEqual(getEventListeners(signal, 'abort').length, 0); | ||
| 129 | 129 | })); | |
| 130 | 130 | } | |
| 131 | 131 | ||
@@ -139,15 +139,15 @@ process.on('multipleResolves', common.mustNotCall()); | |||
| 139 | 139 | // eslint-disable-next-line no-unused-vars | |
| 140 | 140 | for await (const _ of iterator) { | |
| 141 | 141 | if (i === 0) { | |
| 142 | - assert.strictEqual(signal.listenerCount('abort'), 1); | ||
| 142 | + assert.strictEqual(getEventListeners(signal, 'abort').length, 1); | ||
| 143 | 143 | } | |
| 144 | 144 | i++; | |
| 145 | 145 | if (i === 2) { | |
| 146 | 146 | break; | |
| 147 | 147 | } | |
| 148 | 148 | } | |
| 149 | 149 | assert.strictEqual(i, 2); | |
| 150 | - assert.strictEqual(signal.listenerCount('abort'), 0); | ||
| 150 | + assert.strictEqual(getEventListeners(signal, 'abort').length, 0); | ||
| 151 | 151 | } | |
| 152 | 152 | ||
| 153 | 153 | tryBreak().then(common.mustCall()); | |
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
@@ -6,7 +6,7 @@ const timers = require('timers'); | |||
| 6 | 6 | const { promisify } = require('util'); | |
| 7 | 7 | const child_process = require('child_process'); | |
| 8 | 8 | ||
| 9 | - // TODO(benjamingr) - refactor to use getEventListeners when #35991 lands | ||
| 9 | + const { getEventListeners } = require('events'); | ||
| 10 | 10 | const { NodeEventTarget } = require('internal/event_target'); | |
| 11 | 11 | ||
| 12 | 12 | const timerPromises = require('timers/promises'); | |
@@ -60,7 +60,7 @@ process.on('multipleResolves', common.mustNotCall()); | |||
| 60 | 60 | const signal = new NodeEventTarget(); | |
| 61 | 61 | signal.aborted = false; | |
| 62 | 62 | setPromiseTimeout(0, null, { signal }).finally(common.mustCall(() => { | |
| 63 | - assert.strictEqual(signal.listenerCount('abort'), 0); | ||
| 63 | + assert.strictEqual(getEventListeners(signal, 'abort').length, 0); | ||
| 64 | 64 | })); | |
| 65 | 65 | } | |
| 66 | 66 | ||
| Back | FazBrowse Home | New Git URL |
0 commit comments