We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent e5d963e commit 16b32eaCopy full SHA for 16b32ea
lib/internal/quic/core.js
@@ -1688,6 +1688,10 @@ class QuicSession extends EventEmitter {
1688
socket[kAddSession](this);
1689
}
1690
1691
+ [kRejections](err, eventname, ...args) {
1692
+ this.destroy(err);
1693
+ }
1694
+
1695
// Used to get the configured options for peer initiated QuicStream
1696
// instances.
1697
get [kStreamOptions]() {
@@ -1702,7 +1706,11 @@ class QuicSession extends EventEmitter {
1702
1706
const state = this[kInternalState];
1703
1707
state.qlogStream = stream;
1704
1708
process.nextTick(() => {
1705
- this.emit('qlog', state.qlogStream);
1709
+ try {
1710
+ this.emit('qlog', state.qlogStream);
1711
+ } catch (error) {
1712
+ this.destroy(error);
1713
1714
});
1715
1716
0 commit comments