more

src/js/node/http2.ts

@@ -1891,7 +1891,7 @@ class Http2Stream extends Duplex {
       }
       markStreamClosed(this);
       this.rstCode = code;
-      if (this.writableFinished) {
+      if (this.writableFinished || code) {
         setImmediate(rstNextTick.bind(session, this.#id, code));
       } else {
         this.once("finish", rstNextTick.bind(session, this.#id, code));

test/js/node/test/parallel/test-http2-cancel-while-client-reading.js

@@ -28,6 +28,7 @@ server.listen(0, function() {
                                { rejectUnauthorized: false }
   );
   client_stream = client.request({ ':method': 'POST' });
+  
   client_stream.on('close', common.mustCall(() => {
     client.close();
     server.close();