diff --git a/lib/internal/http2/core.js b/lib/internal/http2/core.js index 69f498e3d0e1ef..dadbaefa9ce634 100644 --- a/lib/internal/http2/core.js +++ b/lib/internal/http2/core.js @@ -220,6 +220,7 @@ function onSessionHeaders(handle, id, cat, flags, headers) { } } else { stream = new ClientHttp2Stream(session, handle, id, opts); + stream.end(); } if (endOfStream) stream[kState].endAfterHeaders = true; diff --git a/test/parallel/test-http2-server-push-stream.js b/test/parallel/test-http2-server-push-stream.js index 69e74349475c42..74d41ba4b9c672 100644 --- a/test/parallel/test-http2-server-push-stream.js +++ b/test/parallel/test-http2-server-push-stream.js @@ -54,6 +54,7 @@ server.listen(0, common.mustCall(() => { assert.strictEqual(headers['content-type'], 'text/html'); assert.strictEqual(headers['x-push-data'], 'pushed by server'); })); + stream.on('aborted', common.mustNotCall()); })); let data = '';