@@ -928,7 +928,7 @@ async function once(emitter, name, options = kEmptyObject) {
928
928
const signal = options ?. signal ;
929
929
validateAbortSignal ( signal , 'options.signal' ) ;
930
930
if ( signal ?. aborted )
931
- throw new AbortError ( ) ;
931
+ throw new AbortError ( undefined , { cause : signal ?. reason } ) ;
932
932
return new Promise ( ( resolve , reject ) => {
933
933
const errorListener = ( err ) => {
934
934
emitter . removeListener ( name , resolver ) ;
@@ -955,7 +955,7 @@ async function once(emitter, name, options = kEmptyObject) {
955
955
function abortListener ( ) {
956
956
eventTargetAgnosticRemoveListener ( emitter , name , resolver ) ;
957
957
eventTargetAgnosticRemoveListener ( emitter , 'error' , errorListener ) ;
958
- reject ( new AbortError ( ) ) ;
958
+ reject ( new AbortError ( undefined , { cause : signal ?. reason } ) ) ;
959
959
}
960
960
if ( signal != null ) {
961
961
eventTargetAgnosticAddListener (
@@ -1006,7 +1006,7 @@ function on(emitter, event, options) {
1006
1006
const signal = options ?. signal ;
1007
1007
validateAbortSignal ( signal , 'options.signal' ) ;
1008
1008
if ( signal ?. aborted )
1009
- throw new AbortError ( ) ;
1009
+ throw new AbortError ( undefined , { cause : signal ?. reason } ) ;
1010
1010
1011
1011
const unconsumedEvents = [ ] ;
1012
1012
const unconsumedPromises = [ ] ;
@@ -1094,7 +1094,7 @@ function on(emitter, event, options) {
1094
1094
return iterator ;
1095
1095
1096
1096
function abortListener ( ) {
1097
- errorHandler ( new AbortError ( ) ) ;
1097
+ errorHandler ( new AbortError ( undefined , { cause : signal ?. reason } ) ) ;
1098
1098
}
1099
1099
1100
1100
function eventHandler ( ...args ) {
0 commit comments