quic: handle unhandled rejections on QuicSession

PR-URL: #34283 Reviewed-By: Anna Henningsen <anna@addaleax.net>
nodejs · Jul 16, 2020 · 16b32ea · 16b32ea
1 parent e5d963e
commit 16b32ea
Showing 1 changed file with 9 additions and 1 deletion.
diff --git 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);
+      }
     });
   }