diff --git a/lib/internal/quic/core.js b/lib/internal/quic/core.js index 1af67c031c81fa..65a204decc3e53 100644 --- a/lib/internal/quic/core.js +++ b/lib/internal/quic/core.js @@ -1688,6 +1688,10 @@ class QuicSession extends EventEmitter { socket[kAddSession](this); } + [kRejections](err, eventname, ...args) { + this.destroy(err); + } + // Used to get the configured options for peer initiated QuicStream // instances. get [kStreamOptions]() { @@ -1702,7 +1706,11 @@ class QuicSession extends EventEmitter { const state = this[kInternalState]; state.qlogStream = stream; process.nextTick(() => { - this.emit('qlog', state.qlogStream); + try { + this.emit('qlog', state.qlogStream); + } catch (error) { + this.destroy(error); + } }); }