inspector: fix http2 decompressor end racing

Author: legendecas

lib/internal/inspector/network_http2.js

@@ -35,6 +35,7 @@ const EventEmitter = require('events');
 const { Buffer } = require('buffer');
 
 const kRequestUrl = Symbol('kRequestUrl');
+const kDecompressor = Symbol('kDecompressor');
 
 // Convert a Headers object (Map<string, number | string | string[]>) to a plain object (Map<string, string>)
 function convertHeaderObject(headers = {}) {
@@ -229,6 +230,8 @@ function onClientStreamFinish({ stream, headers }) {
   const decompressor = createDecompressor(contentEncoding);
 
   if (decompressor) {
+    stream[kDecompressor] = decompressor;
+
     // Pipe decompressed data to DevTools
     decompressor.on('data', (decompressedChunk) => {
       Network.dataReceived({
@@ -293,10 +296,21 @@ function onClientStreamClose({ stream }) {
     return;
   }
 
-  Network.loadingFinished({
-    requestId: stream[kInspectorRequestId],
-    timestamp: getMonotonicTime(),
-  });
+  const decompressor = stream[kDecompressor];
+  if (decompressor) {
+    // Wait for the decompressor to flush all data before signaling completion.
+    decompressor.once('end', () => {
+      Network.loadingFinished({
+        requestId: stream[kInspectorRequestId],
+        timestamp: getMonotonicTime(),
+      });
+    });
+  } else {
+    Network.loadingFinished({
+      requestId: stream[kInspectorRequestId],
+      timestamp: getMonotonicTime(),
+    });
+  }
 }
 
 module.exports = registerDiagnosticChannels([