File tree Expand file tree Collapse file tree 2 files changed +11
-3
lines changed Expand file tree Collapse file tree 2 files changed +11
-3
lines changed Original file line number Diff line number Diff line change 1
1
'use strict'
2
2
3
- const { setTimeout } = require ( 'node:timers/promises' )
4
3
const { pipeline } = require ( 'node:stream' )
5
4
const { fetching } = require ( '../fetch' )
6
5
const { makeRequest } = require ( '../fetch/request' )
@@ -11,6 +10,7 @@ const { parseMIMEType } = require('../fetch/dataURL')
11
10
const { MessageEvent } = require ( '../websocket/events' )
12
11
const { isNetworkError } = require ( '../fetch/response' )
13
12
const { getGlobalDispatcher } = require ( '../global' )
13
+ const { delay } = require ( './util' )
14
14
15
15
let experimentalWarned = false
16
16
@@ -344,7 +344,7 @@ class EventSource extends EventTarget {
344
344
this . dispatchEvent ( new Event ( 'error' ) )
345
345
346
346
// 2. Wait a delay equal to the reconnection time of the event source.
347
- await setTimeout ( this . #settings. reconnectionTime , { ref : false } )
347
+ await delay ( this . #settings. reconnectionTime )
348
348
349
349
// 5. Queue a task to run the following steps:
350
350
Original file line number Diff line number Diff line change @@ -23,7 +23,15 @@ function isASCIINumber (value) {
23
23
return true
24
24
}
25
25
26
+ // https://github.com/nodejs/undici/issues/2664
27
+ function delay ( ms ) {
28
+ return new Promise ( ( resolve ) => {
29
+ setTimeout ( resolve , ms ) . unref ( )
30
+ } )
31
+ }
32
+
26
33
module . exports = {
27
34
isValidLastEventId,
28
- isASCIINumber
35
+ isASCIINumber,
36
+ delay
29
37
}
You can’t perform that action at this time.
0 commit comments