quic: convert incoming :status header to number

Signed-off-by: Hallison Melo <hallss93@hotmail.com>
Co-authored-by: Cursor <cursoragent@cursor.com>
PR-URL: #63589Fixes: #63557
Reviewed-By: Stephen Belanger <admin@stephenbelanger.com>
Reviewed-By: Tim Perry <pimterry@gmail.com>

Author: 2 people

doc/api/quic.md

@@ -3980,8 +3980,9 @@ A few things to note:
  the request is `HEADERS` followed by `END_STREAM`.
 * The `onheaders` callback receives the response pseudo-headers and
  regular headers in a single object with lowercase string keys.
- After the callback returns, the same object is also accessible
- via [`stream.headers`][].
+ For incoming headers, the `:status` pseudo-header is converted to
+ a `number`, matching HTTP/2 behavior. After the callback returns,
+ the same object is also accessible via [`stream.headers`][].
 * Reading `for await (const chunks of stream)` consumes the response
  body. Each iteration yields a `Uint8Array[]` batch of chunks.
 * HTTP semantic helpers (URL parsing, method/status validation,

lib/internal/quic/quic.js

@@ -1285,14 +1285,19 @@ function parseHeaderPairs(pairs) {
 assert(pairs.length%2===0);
 constblock={__proto__: null};
 for(letn=0;n+1<pairs.length;n+=2){
-if(block[pairs[n]]!==undefined){
-if(ArrayIsArray(block[pairs[n]])){
-ArrayPrototypePush(block[pairs[n]],pairs[n+1]);
+constname=pairs[n];
+letvalue=pairs[n+1];
+// Match HTTP/2 behavior: incoming :status is exposed as a number.
+if(name===':status')
+value|=0;
+if(block[name]!==undefined){
+if(ArrayIsArray(block[name])){
+ArrayPrototypePush(block[name],value);
 }else{
-block[pairs[n]]=[block[pairs[n]],pairs[n+1]];
+block[name]=[block[name],value];
 }
 }else{
-block[pairs[n]]=pairs[n+1];
+block[name]=value;
 }
 }
 returnblock;

test/parallel/test-quic-h3-callback-errors.mjs

@@ -151,7 +151,7 @@ async function makeServer(onheadersHandler, extraOpts = {}) {
 ':authority': 'localhost',
 },
 onheaders: mustCall(function(headers){
-assert.strictEqual(headers[':status'],'200');
+assert.strictEqual(headers[':status'],200);
 }),
 ontrailers: mustCall(function(){
 thrownewError('ontrailers sync error');
@@ -265,7 +265,7 @@ async function makeServer(onheadersHandler, extraOpts = {}) {
 ':authority': 'localhost',
 },
 onheaders: mustCall(function(headers){
-assert.strictEqual(headers[':status'],'200');
+assert.strictEqual(headers[':status'],200);
 }),
 });
 

test/parallel/test-quic-h3-close-behavior.mjs

@@ -62,7 +62,7 @@ const decoder = new TextDecoder();
 ':authority': 'localhost',
 },
 onheaders: mustCall((headers)=>{
-assert.strictEqual(headers[':status'],'200');
+assert.strictEqual(headers[':status'],200);
 }),
 });
 
@@ -74,7 +74,7 @@ const decoder = new TextDecoder();
 ':authority': 'localhost',
 },
 onheaders: mustCall((headers)=>{
-assert.strictEqual(headers[':status'],'200');
+assert.strictEqual(headers[':status'],200);
 }),
 });
 

test/parallel/test-quic-h3-concurrent-requests.mjs

@@ -72,7 +72,7 @@ const requests = paths.map(mustCall(async (path) => {
 ':authority': 'localhost',
 },
 onheaders: mustCall((headers)=>{
-assert.strictEqual(headers[':status'],'200');
+assert.strictEqual(headers[':status'],200);
 headersReceived.resolve();
 }),
 });

test/parallel/test-quic-h3-datagram.mjs

@@ -87,7 +87,7 @@ const decoder = new TextDecoder();
 ':authority': 'localhost',
 },
 onheaders: mustCall(function(headers){
-assert.strictEqual(headers[':status'],'200');
+assert.strictEqual(headers[':status'],200);
 }),
 });
 
@@ -151,7 +151,7 @@ const decoder = new TextDecoder();
 ':authority': 'localhost',
 },
 onheaders: mustCall((headers)=>{
-assert.strictEqual(headers[':status'],'200');
+assert.strictEqual(headers[':status'],200);
 }),
 });
 

test/parallel/test-quic-h3-error-codes.mjs

@@ -55,7 +55,7 @@ const decoder = new TextDecoder();
 ':authority': 'localhost',
 },
 onheaders: mustCall(function(headers){
-assert.strictEqual(headers[':status'],'200');
+assert.strictEqual(headers[':status'],200);
 }),
 });
 
@@ -106,7 +106,7 @@ const decoder = new TextDecoder();
 ':authority': 'localhost',
 },
 onheaders: mustCall(function(headers){
-assert.strictEqual(headers[':status'],'200');
+assert.strictEqual(headers[':status'],200);
 }),
 });
 

test/parallel/test-quic-h3-goaway.mjs

@@ -78,7 +78,7 @@ dc.subscribe('quic.session.goaway', mustCall((msg) => {
 awaitclientSession.opened;
 
 constonClientHeaders=mustCall(function(headers){
-assert.strictEqual(headers[':status'],'200');
+assert.strictEqual(headers[':status'],200);
 if(++clientHeaderCount===2){
 bothHeadersReceived.resolve();
 }

test/parallel/test-quic-h3-header-validation.mjs

@@ -91,7 +91,7 @@ const decoder = new TextDecoder();
 },
 onheaders: mustCall(function(headers){
 // Client should also receive lowercased response header names.
-assert.strictEqual(headers[':status'],'200');
+assert.strictEqual(headers[':status'],200);
 assert.strictEqual(headers['content-type'],'text/html');
 assert.strictEqual(headers['x-response-header'],'ResponseValue');
 
@@ -148,7 +148,7 @@ const decoder = new TextDecoder();
 ':authority': 'localhost',
 },
 onheaders: mustCall((headers)=>{
-assert.strictEqual(headers[':status'],'204');
+assert.strictEqual(headers[':status'],204);
 }),
 });
 

test/parallel/test-quic-h3-informational-headers.mjs

@@ -34,7 +34,7 @@ dc.subscribe('quic.stream.info', mustCall((msg) => {
 assert.ok(msg.stream,'stream.info should include stream');
 assert.ok(msg.session,'stream.info should include session');
 assert.ok(msg.headers,'stream.info should include headers');
-assert.strictEqual(msg.headers[':status'],'103');
+assert.strictEqual(msg.headers[':status'],103);
 }));
 
 // quic.stream.headers also fires for the final response headers.
@@ -89,12 +89,12 @@ const stream = await clientSession.createBidirectionalStream({
 ':authority': 'localhost',
 },
 oninfo: mustCall(function(headers){
-assert.strictEqual(headers[':status'],'103');
+assert.strictEqual(headers[':status'],103);
 assert.strictEqual(headers.link,'</style.css>; rel=preload; as=style');
 clientInfoReceived.resolve();
 }),
 onheaders: mustCall(function(headers){
-assert.strictEqual(headers[':status'],'200');
+assert.strictEqual(headers[':status'],200);
 assert.strictEqual(headers['content-type'],'text/plain');
 clientHeadersReceived.resolve();
 }),
@@ -107,7 +107,7 @@ const body = await bytes(stream);
 assert.strictEqual(decoder.decode(body),responseBody);
 
 // stream.headers should return the final (initial) headers, not 1xx.
-assert.strictEqual(stream.headers[':status'],'200');
+assert.strictEqual(stream.headers[':status'],200);
 
 awaitPromise.all([stream.closed,serverDone.promise]);
 awaitclientSession.close();

doc/api/quic.md

@@ -3980,8 +3980,9 @@ A few things to note:
  the request is `HEADERS` followed by `END_STREAM`.
 * The `onheaders` callback receives the response pseudo-headers and
  regular headers in a single object with lowercase string keys.
- After the callback returns, the same object is also accessible
- via [`stream.headers`][].
+ For incoming headers, the `:status` pseudo-header is converted to
+ a `number`, matching HTTP/2 behavior. After the callback returns,
+ the same object is also accessible via [`stream.headers`][].
 * Reading `for await (const chunks of stream)` consumes the response
  body. Each iteration yields a `Uint8Array[]` batch of chunks.
 * HTTP semantic helpers (URL parsing, method/status validation,

lib/internal/quic/quic.js

@@ -1285,14 +1285,19 @@ function parseHeaderPairs(pairs) {
 assert(pairs.length%2===0);
 constblock={__proto__: null};
 for(letn=0;n+1<pairs.length;n+=2){
-if(block[pairs[n]]!==undefined){
-if(ArrayIsArray(block[pairs[n]])){
-ArrayPrototypePush(block[pairs[n]],pairs[n+1]);
+constname=pairs[n];
+letvalue=pairs[n+1];
+// Match HTTP/2 behavior: incoming :status is exposed as a number.
+if(name===':status')
+value|=0;
+if(block[name]!==undefined){
+if(ArrayIsArray(block[name])){
+ArrayPrototypePush(block[name],value);
 }else{
-block[pairs[n]]=[block[pairs[n]],pairs[n+1]];
+block[name]=[block[name],value];
 }
 }else{
-block[pairs[n]]=pairs[n+1];
+block[name]=value;
 }
 }
 returnblock;

test/parallel/test-quic-h3-callback-errors.mjs

@@ -151,7 +151,7 @@ async function makeServer(onheadersHandler, extraOpts = {}) {
 ':authority': 'localhost',
 },
 onheaders: mustCall(function(headers){
-assert.strictEqual(headers[':status'],'200');
+assert.strictEqual(headers[':status'],200);
 }),
 ontrailers: mustCall(function(){
 thrownewError('ontrailers sync error');
@@ -265,7 +265,7 @@ async function makeServer(onheadersHandler, extraOpts = {}) {
 ':authority': 'localhost',
 },
 onheaders: mustCall(function(headers){
-assert.strictEqual(headers[':status'],'200');
+assert.strictEqual(headers[':status'],200);
 }),
 });
 

test/parallel/test-quic-h3-close-behavior.mjs

@@ -62,7 +62,7 @@ const decoder = new TextDecoder();
 ':authority': 'localhost',
 },
 onheaders: mustCall((headers)=>{
-assert.strictEqual(headers[':status'],'200');
+assert.strictEqual(headers[':status'],200);
 }),
 });
 
@@ -74,7 +74,7 @@ const decoder = new TextDecoder();
 ':authority': 'localhost',
 },
 onheaders: mustCall((headers)=>{
-assert.strictEqual(headers[':status'],'200');
+assert.strictEqual(headers[':status'],200);
 }),
 });
 

test/parallel/test-quic-h3-concurrent-requests.mjs

@@ -72,7 +72,7 @@ const requests = paths.map(mustCall(async (path) => {
 ':authority': 'localhost',
 },
 onheaders: mustCall((headers)=>{
-assert.strictEqual(headers[':status'],'200');
+assert.strictEqual(headers[':status'],200);
 headersReceived.resolve();
 }),
 });

test/parallel/test-quic-h3-datagram.mjs

@@ -87,7 +87,7 @@ const decoder = new TextDecoder();
 ':authority': 'localhost',
 },
 onheaders: mustCall(function(headers){
-assert.strictEqual(headers[':status'],'200');
+assert.strictEqual(headers[':status'],200);
 }),
 });
 
@@ -151,7 +151,7 @@ const decoder = new TextDecoder();
 ':authority': 'localhost',
 },
 onheaders: mustCall((headers)=>{
-assert.strictEqual(headers[':status'],'200');
+assert.strictEqual(headers[':status'],200);
 }),
 });
 

test/parallel/test-quic-h3-error-codes.mjs

@@ -55,7 +55,7 @@ const decoder = new TextDecoder();
 ':authority': 'localhost',
 },
 onheaders: mustCall(function(headers){
-assert.strictEqual(headers[':status'],'200');
+assert.strictEqual(headers[':status'],200);
 }),
 });
 
@@ -106,7 +106,7 @@ const decoder = new TextDecoder();
 ':authority': 'localhost',
 },
 onheaders: mustCall(function(headers){
-assert.strictEqual(headers[':status'],'200');
+assert.strictEqual(headers[':status'],200);
 }),
 });
 

test/parallel/test-quic-h3-goaway.mjs

@@ -78,7 +78,7 @@ dc.subscribe('quic.session.goaway', mustCall((msg) => {
 awaitclientSession.opened;
 
 constonClientHeaders=mustCall(function(headers){
-assert.strictEqual(headers[':status'],'200');
+assert.strictEqual(headers[':status'],200);
 if(++clientHeaderCount===2){
 bothHeadersReceived.resolve();
 }

test/parallel/test-quic-h3-header-validation.mjs

@@ -91,7 +91,7 @@ const decoder = new TextDecoder();
 },
 onheaders: mustCall(function(headers){
 // Client should also receive lowercased response header names.
-assert.strictEqual(headers[':status'],'200');
+assert.strictEqual(headers[':status'],200);
 assert.strictEqual(headers['content-type'],'text/html');
 assert.strictEqual(headers['x-response-header'],'ResponseValue');
 
@@ -148,7 +148,7 @@ const decoder = new TextDecoder();
 ':authority': 'localhost',
 },
 onheaders: mustCall((headers)=>{
-assert.strictEqual(headers[':status'],'204');
+assert.strictEqual(headers[':status'],204);
 }),
 });
 

test/parallel/test-quic-h3-informational-headers.mjs

@@ -34,7 +34,7 @@ dc.subscribe('quic.stream.info', mustCall((msg) => {
 assert.ok(msg.stream,'stream.info should include stream');
 assert.ok(msg.session,'stream.info should include session');
 assert.ok(msg.headers,'stream.info should include headers');
-assert.strictEqual(msg.headers[':status'],'103');
+assert.strictEqual(msg.headers[':status'],103);
 }));
 
 // quic.stream.headers also fires for the final response headers.
@@ -89,12 +89,12 @@ const stream = await clientSession.createBidirectionalStream({
 ':authority': 'localhost',
 },
 oninfo: mustCall(function(headers){
-assert.strictEqual(headers[':status'],'103');
+assert.strictEqual(headers[':status'],103);
 assert.strictEqual(headers.link,'</style.css>; rel=preload; as=style');
 clientInfoReceived.resolve();
 }),
 onheaders: mustCall(function(headers){
-assert.strictEqual(headers[':status'],'200');
+assert.strictEqual(headers[':status'],200);
 assert.strictEqual(headers['content-type'],'text/plain');
 clientHeadersReceived.resolve();
 }),
@@ -107,7 +107,7 @@ const body = await bytes(stream);
 assert.strictEqual(decoder.decode(body),responseBody);
 
 // stream.headers should return the final (initial) headers, not 1xx.
-assert.strictEqual(stream.headers[':status'],'200');
+assert.strictEqual(stream.headers[':status'],200);
 
 awaitPromise.all([stream.closed,serverDone.promise]);
 awaitclientSession.close();

doc/api/quic.md

@@ -3980,8 +3980,9 @@ A few things to note:
  the request is `HEADERS` followed by `END_STREAM`.
 * The `onheaders` callback receives the response pseudo-headers and
  regular headers in a single object with lowercase string keys.
- After the callback returns, the same object is also accessible
- via [`stream.headers`][].
+ For incoming headers, the `:status` pseudo-header is converted to
+ a `number`, matching HTTP/2 behavior. After the callback returns,
+ the same object is also accessible via [`stream.headers`][].
 * Reading `for await (const chunks of stream)` consumes the response
  body. Each iteration yields a `Uint8Array[]` batch of chunks.
 * HTTP semantic helpers (URL parsing, method/status validation,

lib/internal/quic/quic.js

@@ -1285,14 +1285,19 @@ function parseHeaderPairs(pairs) {
 assert(pairs.length%2===0);
 constblock={__proto__: null};
 for(letn=0;n+1<pairs.length;n+=2){
-if(block[pairs[n]]!==undefined){
-if(ArrayIsArray(block[pairs[n]])){
-ArrayPrototypePush(block[pairs[n]],pairs[n+1]);
+constname=pairs[n];
+letvalue=pairs[n+1];
+// Match HTTP/2 behavior: incoming :status is exposed as a number.
+if(name===':status')
+value|=0;
+if(block[name]!==undefined){
+if(ArrayIsArray(block[name])){
+ArrayPrototypePush(block[name],value);
 }else{
-block[pairs[n]]=[block[pairs[n]],pairs[n+1]];
+block[name]=[block[name],value];
 }
 }else{
-block[pairs[n]]=pairs[n+1];
+block[name]=value;
 }
 }
 returnblock;

test/parallel/test-quic-h3-callback-errors.mjs

@@ -151,7 +151,7 @@ async function makeServer(onheadersHandler, extraOpts = {}) {
 ':authority': 'localhost',
 },
 onheaders: mustCall(function(headers){
-assert.strictEqual(headers[':status'],'200');
+assert.strictEqual(headers[':status'],200);
 }),
 ontrailers: mustCall(function(){
 thrownewError('ontrailers sync error');
@@ -265,7 +265,7 @@ async function makeServer(onheadersHandler, extraOpts = {}) {
 ':authority': 'localhost',
 },
 onheaders: mustCall(function(headers){
-assert.strictEqual(headers[':status'],'200');
+assert.strictEqual(headers[':status'],200);
 }),
 });
 

test/parallel/test-quic-h3-close-behavior.mjs

@@ -62,7 +62,7 @@ const decoder = new TextDecoder();
 ':authority': 'localhost',
 },
 onheaders: mustCall((headers)=>{
-assert.strictEqual(headers[':status'],'200');
+assert.strictEqual(headers[':status'],200);
 }),
 });
 
@@ -74,7 +74,7 @@ const decoder = new TextDecoder();
 ':authority': 'localhost',
 },
 onheaders: mustCall((headers)=>{
-assert.strictEqual(headers[':status'],'200');
+assert.strictEqual(headers[':status'],200);
 }),
 });
 

test/parallel/test-quic-h3-concurrent-requests.mjs

@@ -72,7 +72,7 @@ const requests = paths.map(mustCall(async (path) => {
 ':authority': 'localhost',
 },
 onheaders: mustCall((headers)=>{
-assert.strictEqual(headers[':status'],'200');
+assert.strictEqual(headers[':status'],200);
 headersReceived.resolve();
 }),
 });

test/parallel/test-quic-h3-datagram.mjs

@@ -87,7 +87,7 @@ const decoder = new TextDecoder();
 ':authority': 'localhost',
 },
 onheaders: mustCall(function(headers){
-assert.strictEqual(headers[':status'],'200');
+assert.strictEqual(headers[':status'],200);
 }),
 });
 
@@ -151,7 +151,7 @@ const decoder = new TextDecoder();
 ':authority': 'localhost',
 },
 onheaders: mustCall((headers)=>{
-assert.strictEqual(headers[':status'],'200');
+assert.strictEqual(headers[':status'],200);
 }),
 });
 

test/parallel/test-quic-h3-error-codes.mjs

@@ -55,7 +55,7 @@ const decoder = new TextDecoder();
 ':authority': 'localhost',
 },
 onheaders: mustCall(function(headers){
-assert.strictEqual(headers[':status'],'200');
+assert.strictEqual(headers[':status'],200);
 }),
 });
 
@@ -106,7 +106,7 @@ const decoder = new TextDecoder();
 ':authority': 'localhost',
 },
 onheaders: mustCall(function(headers){
-assert.strictEqual(headers[':status'],'200');
+assert.strictEqual(headers[':status'],200);
 }),
 });
 

test/parallel/test-quic-h3-goaway.mjs

@@ -78,7 +78,7 @@ dc.subscribe('quic.session.goaway', mustCall((msg) => {
 awaitclientSession.opened;
 
 constonClientHeaders=mustCall(function(headers){
-assert.strictEqual(headers[':status'],'200');
+assert.strictEqual(headers[':status'],200);
 if(++clientHeaderCount===2){
 bothHeadersReceived.resolve();
 }

test/parallel/test-quic-h3-header-validation.mjs

@@ -91,7 +91,7 @@ const decoder = new TextDecoder();
 },
 onheaders: mustCall(function(headers){
 // Client should also receive lowercased response header names.
-assert.strictEqual(headers[':status'],'200');
+assert.strictEqual(headers[':status'],200);
 assert.strictEqual(headers['content-type'],'text/html');
 assert.strictEqual(headers['x-response-header'],'ResponseValue');
 
@@ -148,7 +148,7 @@ const decoder = new TextDecoder();
 ':authority': 'localhost',
 },
 onheaders: mustCall((headers)=>{
-assert.strictEqual(headers[':status'],'204');
+assert.strictEqual(headers[':status'],204);
 }),
 });
 

test/parallel/test-quic-h3-informational-headers.mjs

@@ -34,7 +34,7 @@ dc.subscribe('quic.stream.info', mustCall((msg) => {
 assert.ok(msg.stream,'stream.info should include stream');
 assert.ok(msg.session,'stream.info should include session');
 assert.ok(msg.headers,'stream.info should include headers');
-assert.strictEqual(msg.headers[':status'],'103');
+assert.strictEqual(msg.headers[':status'],103);
 }));
 
 // quic.stream.headers also fires for the final response headers.
@@ -89,12 +89,12 @@ const stream = await clientSession.createBidirectionalStream({
 ':authority': 'localhost',
 },
 oninfo: mustCall(function(headers){
-assert.strictEqual(headers[':status'],'103');
+assert.strictEqual(headers[':status'],103);
 assert.strictEqual(headers.link,'</style.css>; rel=preload; as=style');
 clientInfoReceived.resolve();
 }),
 onheaders: mustCall(function(headers){
-assert.strictEqual(headers[':status'],'200');
+assert.strictEqual(headers[':status'],200);
 assert.strictEqual(headers['content-type'],'text/plain');
 clientHeadersReceived.resolve();
 }),
@@ -107,7 +107,7 @@ const body = await bytes(stream);
 assert.strictEqual(decoder.decode(body),responseBody);
 
 // stream.headers should return the final (initial) headers, not 1xx.
-assert.strictEqual(stream.headers[':status'],'200');
+assert.strictEqual(stream.headers[':status'],200);
 
 awaitPromise.all([stream.closed,serverDone.promise]);
 awaitclientSession.close();

doc/api/quic.md

@@ -3980,8 +3980,9 @@ A few things to note:
  the request is `HEADERS` followed by `END_STREAM`.
 * The `onheaders` callback receives the response pseudo-headers and
  regular headers in a single object with lowercase string keys.
- After the callback returns, the same object is also accessible
- via [`stream.headers`][].
+ For incoming headers, the `:status` pseudo-header is converted to
+ a `number`, matching HTTP/2 behavior. After the callback returns,
+ the same object is also accessible via [`stream.headers`][].
 * Reading `for await (const chunks of stream)` consumes the response
  body. Each iteration yields a `Uint8Array[]` batch of chunks.
 * HTTP semantic helpers (URL parsing, method/status validation,

lib/internal/quic/quic.js

@@ -1285,14 +1285,19 @@ function parseHeaderPairs(pairs) {
 assert(pairs.length%2===0);
 constblock={__proto__: null};
 for(letn=0;n+1<pairs.length;n+=2){
-if(block[pairs[n]]!==undefined){
-if(ArrayIsArray(block[pairs[n]])){
-ArrayPrototypePush(block[pairs[n]],pairs[n+1]);
+constname=pairs[n];
+letvalue=pairs[n+1];
+// Match HTTP/2 behavior: incoming :status is exposed as a number.
+if(name===':status')
+value|=0;
+if(block[name]!==undefined){
+if(ArrayIsArray(block[name])){
+ArrayPrototypePush(block[name],value);
 }else{
-block[pairs[n]]=[block[pairs[n]],pairs[n+1]];
+block[name]=[block[name],value];
 }
 }else{
-block[pairs[n]]=pairs[n+1];
+block[name]=value;
 }
 }
 returnblock;

test/parallel/test-quic-h3-callback-errors.mjs

@@ -151,7 +151,7 @@ async function makeServer(onheadersHandler, extraOpts = {}) {
 ':authority': 'localhost',
 },
 onheaders: mustCall(function(headers){
-assert.strictEqual(headers[':status'],'200');
+assert.strictEqual(headers[':status'],200);
 }),
 ontrailers: mustCall(function(){
 thrownewError('ontrailers sync error');
@@ -265,7 +265,7 @@ async function makeServer(onheadersHandler, extraOpts = {}) {
 ':authority': 'localhost',
 },
 onheaders: mustCall(function(headers){
-assert.strictEqual(headers[':status'],'200');
+assert.strictEqual(headers[':status'],200);
 }),
 });
 

test/parallel/test-quic-h3-close-behavior.mjs

@@ -62,7 +62,7 @@ const decoder = new TextDecoder();
 ':authority': 'localhost',
 },
 onheaders: mustCall((headers)=>{
-assert.strictEqual(headers[':status'],'200');
+assert.strictEqual(headers[':status'],200);
 }),
 });
 
@@ -74,7 +74,7 @@ const decoder = new TextDecoder();
 ':authority': 'localhost',
 },
 onheaders: mustCall((headers)=>{
-assert.strictEqual(headers[':status'],'200');
+assert.strictEqual(headers[':status'],200);
 }),
 });
 

test/parallel/test-quic-h3-concurrent-requests.mjs

@@ -72,7 +72,7 @@ const requests = paths.map(mustCall(async (path) => {
 ':authority': 'localhost',
 },
 onheaders: mustCall((headers)=>{
-assert.strictEqual(headers[':status'],'200');
+assert.strictEqual(headers[':status'],200);
 headersReceived.resolve();
 }),
 });

test/parallel/test-quic-h3-datagram.mjs

@@ -87,7 +87,7 @@ const decoder = new TextDecoder();
 ':authority': 'localhost',
 },
 onheaders: mustCall(function(headers){
-assert.strictEqual(headers[':status'],'200');
+assert.strictEqual(headers[':status'],200);
 }),
 });
 
@@ -151,7 +151,7 @@ const decoder = new TextDecoder();
 ':authority': 'localhost',
 },
 onheaders: mustCall((headers)=>{
-assert.strictEqual(headers[':status'],'200');
+assert.strictEqual(headers[':status'],200);
 }),
 });
 

test/parallel/test-quic-h3-error-codes.mjs

@@ -55,7 +55,7 @@ const decoder = new TextDecoder();
 ':authority': 'localhost',
 },
 onheaders: mustCall(function(headers){
-assert.strictEqual(headers[':status'],'200');
+assert.strictEqual(headers[':status'],200);
 }),
 });
 
@@ -106,7 +106,7 @@ const decoder = new TextDecoder();
 ':authority': 'localhost',
 },
 onheaders: mustCall(function(headers){
-assert.strictEqual(headers[':status'],'200');
+assert.strictEqual(headers[':status'],200);
 }),
 });
 

test/parallel/test-quic-h3-goaway.mjs

@@ -78,7 +78,7 @@ dc.subscribe('quic.session.goaway', mustCall((msg) => {
 awaitclientSession.opened;
 
 constonClientHeaders=mustCall(function(headers){
-assert.strictEqual(headers[':status'],'200');
+assert.strictEqual(headers[':status'],200);
 if(++clientHeaderCount===2){
 bothHeadersReceived.resolve();
 }

test/parallel/test-quic-h3-header-validation.mjs

@@ -91,7 +91,7 @@ const decoder = new TextDecoder();
 },
 onheaders: mustCall(function(headers){
 // Client should also receive lowercased response header names.
-assert.strictEqual(headers[':status'],'200');
+assert.strictEqual(headers[':status'],200);
 assert.strictEqual(headers['content-type'],'text/html');
 assert.strictEqual(headers['x-response-header'],'ResponseValue');
 
@@ -148,7 +148,7 @@ const decoder = new TextDecoder();
 ':authority': 'localhost',
 },
 onheaders: mustCall((headers)=>{
-assert.strictEqual(headers[':status'],'204');
+assert.strictEqual(headers[':status'],204);
 }),
 });
 

test/parallel/test-quic-h3-informational-headers.mjs

@@ -34,7 +34,7 @@ dc.subscribe('quic.stream.info', mustCall((msg) => {
 assert.ok(msg.stream,'stream.info should include stream');
 assert.ok(msg.session,'stream.info should include session');
 assert.ok(msg.headers,'stream.info should include headers');
-assert.strictEqual(msg.headers[':status'],'103');
+assert.strictEqual(msg.headers[':status'],103);
 }));
 
 // quic.stream.headers also fires for the final response headers.
@@ -89,12 +89,12 @@ const stream = await clientSession.createBidirectionalStream({
 ':authority': 'localhost',
 },
 oninfo: mustCall(function(headers){
-assert.strictEqual(headers[':status'],'103');
+assert.strictEqual(headers[':status'],103);
 assert.strictEqual(headers.link,'</style.css>; rel=preload; as=style');
 clientInfoReceived.resolve();
 }),
 onheaders: mustCall(function(headers){
-assert.strictEqual(headers[':status'],'200');
+assert.strictEqual(headers[':status'],200);
 assert.strictEqual(headers['content-type'],'text/plain');
 clientHeadersReceived.resolve();
 }),
@@ -107,7 +107,7 @@ const body = await bytes(stream);
 assert.strictEqual(decoder.decode(body),responseBody);
 
 // stream.headers should return the final (initial) headers, not 1xx.
-assert.strictEqual(stream.headers[':status'],'200');
+assert.strictEqual(stream.headers[':status'],200);
 
 awaitPromise.all([stream.closed,serverDone.promise]);
 awaitclientSession.close();

doc/api/quic.md

@@ -3980,8 +3980,9 @@ A few things to note:
  the request is `HEADERS` followed by `END_STREAM`.
 * The `onheaders` callback receives the response pseudo-headers and
  regular headers in a single object with lowercase string keys.
- After the callback returns, the same object is also accessible
- via [`stream.headers`][].
+ For incoming headers, the `:status` pseudo-header is converted to
+ a `number`, matching HTTP/2 behavior. After the callback returns,
+ the same object is also accessible via [`stream.headers`][].
 * Reading `for await (const chunks of stream)` consumes the response
  body. Each iteration yields a `Uint8Array[]` batch of chunks.
 * HTTP semantic helpers (URL parsing, method/status validation,

lib/internal/quic/quic.js

@@ -1285,14 +1285,19 @@ function parseHeaderPairs(pairs) {
 assert(pairs.length%2===0);
 constblock={__proto__: null};
 for(letn=0;n+1<pairs.length;n+=2){
-if(block[pairs[n]]!==undefined){
-if(ArrayIsArray(block[pairs[n]])){
-ArrayPrototypePush(block[pairs[n]],pairs[n+1]);
+constname=pairs[n];
+letvalue=pairs[n+1];
+// Match HTTP/2 behavior: incoming :status is exposed as a number.
+if(name===':status')
+value|=0;
+if(block[name]!==undefined){
+if(ArrayIsArray(block[name])){
+ArrayPrototypePush(block[name],value);
 }else{
-block[pairs[n]]=[block[pairs[n]],pairs[n+1]];
+block[name]=[block[name],value];
 }
 }else{
-block[pairs[n]]=pairs[n+1];
+block[name]=value;
 }
 }
 returnblock;

test/parallel/test-quic-h3-callback-errors.mjs

@@ -151,7 +151,7 @@ async function makeServer(onheadersHandler, extraOpts = {}) {
 ':authority': 'localhost',
 },
 onheaders: mustCall(function(headers){
-assert.strictEqual(headers[':status'],'200');
+assert.strictEqual(headers[':status'],200);
 }),
 ontrailers: mustCall(function(){
 thrownewError('ontrailers sync error');
@@ -265,7 +265,7 @@ async function makeServer(onheadersHandler, extraOpts = {}) {
 ':authority': 'localhost',
 },
 onheaders: mustCall(function(headers){
-assert.strictEqual(headers[':status'],'200');
+assert.strictEqual(headers[':status'],200);
 }),
 });
 

test/parallel/test-quic-h3-close-behavior.mjs

@@ -62,7 +62,7 @@ const decoder = new TextDecoder();
 ':authority': 'localhost',
 },
 onheaders: mustCall((headers)=>{
-assert.strictEqual(headers[':status'],'200');
+assert.strictEqual(headers[':status'],200);
 }),
 });
 
@@ -74,7 +74,7 @@ const decoder = new TextDecoder();
 ':authority': 'localhost',
 },
 onheaders: mustCall((headers)=>{
-assert.strictEqual(headers[':status'],'200');
+assert.strictEqual(headers[':status'],200);
 }),
 });
 

test/parallel/test-quic-h3-concurrent-requests.mjs

@@ -72,7 +72,7 @@ const requests = paths.map(mustCall(async (path) => {
 ':authority': 'localhost',
 },
 onheaders: mustCall((headers)=>{
-assert.strictEqual(headers[':status'],'200');
+assert.strictEqual(headers[':status'],200);
 headersReceived.resolve();
 }),
 });

test/parallel/test-quic-h3-datagram.mjs

@@ -87,7 +87,7 @@ const decoder = new TextDecoder();
 ':authority': 'localhost',
 },
 onheaders: mustCall(function(headers){
-assert.strictEqual(headers[':status'],'200');
+assert.strictEqual(headers[':status'],200);
 }),
 });
 
@@ -151,7 +151,7 @@ const decoder = new TextDecoder();
 ':authority': 'localhost',
 },
 onheaders: mustCall((headers)=>{
-assert.strictEqual(headers[':status'],'200');
+assert.strictEqual(headers[':status'],200);
 }),
 });
 

test/parallel/test-quic-h3-error-codes.mjs

@@ -55,7 +55,7 @@ const decoder = new TextDecoder();
 ':authority': 'localhost',
 },
 onheaders: mustCall(function(headers){
-assert.strictEqual(headers[':status'],'200');
+assert.strictEqual(headers[':status'],200);
 }),
 });
 
@@ -106,7 +106,7 @@ const decoder = new TextDecoder();
 ':authority': 'localhost',
 },
 onheaders: mustCall(function(headers){
-assert.strictEqual(headers[':status'],'200');
+assert.strictEqual(headers[':status'],200);
 }),
 });
 

test/parallel/test-quic-h3-goaway.mjs

@@ -78,7 +78,7 @@ dc.subscribe('quic.session.goaway', mustCall((msg) => {
 awaitclientSession.opened;
 
 constonClientHeaders=mustCall(function(headers){
-assert.strictEqual(headers[':status'],'200');
+assert.strictEqual(headers[':status'],200);
 if(++clientHeaderCount===2){
 bothHeadersReceived.resolve();
 }

test/parallel/test-quic-h3-header-validation.mjs

@@ -91,7 +91,7 @@ const decoder = new TextDecoder();
 },
 onheaders: mustCall(function(headers){
 // Client should also receive lowercased response header names.
-assert.strictEqual(headers[':status'],'200');
+assert.strictEqual(headers[':status'],200);
 assert.strictEqual(headers['content-type'],'text/html');
 assert.strictEqual(headers['x-response-header'],'ResponseValue');
 
@@ -148,7 +148,7 @@ const decoder = new TextDecoder();
 ':authority': 'localhost',
 },
 onheaders: mustCall((headers)=>{
-assert.strictEqual(headers[':status'],'204');
+assert.strictEqual(headers[':status'],204);
 }),
 });
 

test/parallel/test-quic-h3-informational-headers.mjs

@@ -34,7 +34,7 @@ dc.subscribe('quic.stream.info', mustCall((msg) => {
 assert.ok(msg.stream,'stream.info should include stream');
 assert.ok(msg.session,'stream.info should include session');
 assert.ok(msg.headers,'stream.info should include headers');
-assert.strictEqual(msg.headers[':status'],'103');
+assert.strictEqual(msg.headers[':status'],103);
 }));
 
 // quic.stream.headers also fires for the final response headers.
@@ -89,12 +89,12 @@ const stream = await clientSession.createBidirectionalStream({
 ':authority': 'localhost',
 },
 oninfo: mustCall(function(headers){
-assert.strictEqual(headers[':status'],'103');
+assert.strictEqual(headers[':status'],103);
 assert.strictEqual(headers.link,'</style.css>; rel=preload; as=style');
 clientInfoReceived.resolve();
 }),
 onheaders: mustCall(function(headers){
-assert.strictEqual(headers[':status'],'200');
+assert.strictEqual(headers[':status'],200);
 assert.strictEqual(headers['content-type'],'text/plain');
 clientHeadersReceived.resolve();
 }),
@@ -107,7 +107,7 @@ const body = await bytes(stream);
 assert.strictEqual(decoder.decode(body),responseBody);
 
 // stream.headers should return the final (initial) headers, not 1xx.
-assert.strictEqual(stream.headers[':status'],'200');
+assert.strictEqual(stream.headers[':status'],200);
 
 awaitPromise.all([stream.closed,serverDone.promise]);
 awaitclientSession.close();

doc/api/quic.md

@@ -3980,8 +3980,9 @@ A few things to note:
  the request is `HEADERS` followed by `END_STREAM`.
 * The `onheaders` callback receives the response pseudo-headers and
  regular headers in a single object with lowercase string keys.
- After the callback returns, the same object is also accessible
- via [`stream.headers`][].
+ For incoming headers, the `:status` pseudo-header is converted to
+ a `number`, matching HTTP/2 behavior. After the callback returns,
+ the same object is also accessible via [`stream.headers`][].
 * Reading `for await (const chunks of stream)` consumes the response
  body. Each iteration yields a `Uint8Array[]` batch of chunks.
 * HTTP semantic helpers (URL parsing, method/status validation,

lib/internal/quic/quic.js

@@ -1285,14 +1285,19 @@ function parseHeaderPairs(pairs) {
 assert(pairs.length%2===0);
 constblock={__proto__: null};
 for(letn=0;n+1<pairs.length;n+=2){
-if(block[pairs[n]]!==undefined){
-if(ArrayIsArray(block[pairs[n]])){
-ArrayPrototypePush(block[pairs[n]],pairs[n+1]);
+constname=pairs[n];
+letvalue=pairs[n+1];
+// Match HTTP/2 behavior: incoming :status is exposed as a number.
+if(name===':status')
+value|=0;
+if(block[name]!==undefined){
+if(ArrayIsArray(block[name])){
+ArrayPrototypePush(block[name],value);
 }else{
-block[pairs[n]]=[block[pairs[n]],pairs[n+1]];
+block[name]=[block[name],value];
 }
 }else{
-block[pairs[n]]=pairs[n+1];
+block[name]=value;
 }
 }
 returnblock;

test/parallel/test-quic-h3-callback-errors.mjs

@@ -151,7 +151,7 @@ async function makeServer(onheadersHandler, extraOpts = {}) {
 ':authority': 'localhost',
 },
 onheaders: mustCall(function(headers){
-assert.strictEqual(headers[':status'],'200');
+assert.strictEqual(headers[':status'],200);
 }),
 ontrailers: mustCall(function(){
 thrownewError('ontrailers sync error');
@@ -265,7 +265,7 @@ async function makeServer(onheadersHandler, extraOpts = {}) {
 ':authority': 'localhost',
 },
 onheaders: mustCall(function(headers){
-assert.strictEqual(headers[':status'],'200');
+assert.strictEqual(headers[':status'],200);
 }),
 });
 

test/parallel/test-quic-h3-close-behavior.mjs

@@ -62,7 +62,7 @@ const decoder = new TextDecoder();
 ':authority': 'localhost',
 },
 onheaders: mustCall((headers)=>{
-assert.strictEqual(headers[':status'],'200');
+assert.strictEqual(headers[':status'],200);
 }),
 });
 
@@ -74,7 +74,7 @@ const decoder = new TextDecoder();
 ':authority': 'localhost',
 },
 onheaders: mustCall((headers)=>{
-assert.strictEqual(headers[':status'],'200');
+assert.strictEqual(headers[':status'],200);
 }),
 });
 

test/parallel/test-quic-h3-concurrent-requests.mjs

@@ -72,7 +72,7 @@ const requests = paths.map(mustCall(async (path) => {
 ':authority': 'localhost',
 },
 onheaders: mustCall((headers)=>{
-assert.strictEqual(headers[':status'],'200');
+assert.strictEqual(headers[':status'],200);
 headersReceived.resolve();
 }),
 });

test/parallel/test-quic-h3-datagram.mjs

@@ -87,7 +87,7 @@ const decoder = new TextDecoder();
 ':authority': 'localhost',
 },
 onheaders: mustCall(function(headers){
-assert.strictEqual(headers[':status'],'200');
+assert.strictEqual(headers[':status'],200);
 }),
 });
 
@@ -151,7 +151,7 @@ const decoder = new TextDecoder();
 ':authority': 'localhost',
 },
 onheaders: mustCall((headers)=>{
-assert.strictEqual(headers[':status'],'200');
+assert.strictEqual(headers[':status'],200);
 }),
 });
 

test/parallel/test-quic-h3-error-codes.mjs

@@ -55,7 +55,7 @@ const decoder = new TextDecoder();
 ':authority': 'localhost',
 },
 onheaders: mustCall(function(headers){
-assert.strictEqual(headers[':status'],'200');
+assert.strictEqual(headers[':status'],200);
 }),
 });
 
@@ -106,7 +106,7 @@ const decoder = new TextDecoder();
 ':authority': 'localhost',
 },
 onheaders: mustCall(function(headers){
-assert.strictEqual(headers[':status'],'200');
+assert.strictEqual(headers[':status'],200);
 }),
 });
 

test/parallel/test-quic-h3-goaway.mjs

@@ -78,7 +78,7 @@ dc.subscribe('quic.session.goaway', mustCall((msg) => {
 awaitclientSession.opened;
 
 constonClientHeaders=mustCall(function(headers){
-assert.strictEqual(headers[':status'],'200');
+assert.strictEqual(headers[':status'],200);
 if(++clientHeaderCount===2){
 bothHeadersReceived.resolve();
 }

test/parallel/test-quic-h3-header-validation.mjs

@@ -91,7 +91,7 @@ const decoder = new TextDecoder();
 },
 onheaders: mustCall(function(headers){
 // Client should also receive lowercased response header names.
-assert.strictEqual(headers[':status'],'200');
+assert.strictEqual(headers[':status'],200);
 assert.strictEqual(headers['content-type'],'text/html');
 assert.strictEqual(headers['x-response-header'],'ResponseValue');
 
@@ -148,7 +148,7 @@ const decoder = new TextDecoder();
 ':authority': 'localhost',
 },
 onheaders: mustCall((headers)=>{
-assert.strictEqual(headers[':status'],'204');
+assert.strictEqual(headers[':status'],204);
 }),
 });
 

test/parallel/test-quic-h3-informational-headers.mjs

@@ -34,7 +34,7 @@ dc.subscribe('quic.stream.info', mustCall((msg) => {
 assert.ok(msg.stream,'stream.info should include stream');
 assert.ok(msg.session,'stream.info should include session');
 assert.ok(msg.headers,'stream.info should include headers');
-assert.strictEqual(msg.headers[':status'],'103');
+assert.strictEqual(msg.headers[':status'],103);
 }));
 
 // quic.stream.headers also fires for the final response headers.
@@ -89,12 +89,12 @@ const stream = await clientSession.createBidirectionalStream({
 ':authority': 'localhost',
 },
 oninfo: mustCall(function(headers){
-assert.strictEqual(headers[':status'],'103');
+assert.strictEqual(headers[':status'],103);
 assert.strictEqual(headers.link,'</style.css>; rel=preload; as=style');
 clientInfoReceived.resolve();
 }),
 onheaders: mustCall(function(headers){
-assert.strictEqual(headers[':status'],'200');
+assert.strictEqual(headers[':status'],200);
 assert.strictEqual(headers['content-type'],'text/plain');
 clientHeadersReceived.resolve();
 }),
@@ -107,7 +107,7 @@ const body = await bytes(stream);
 assert.strictEqual(decoder.decode(body),responseBody);
 
 // stream.headers should return the final (initial) headers, not 1xx.
-assert.strictEqual(stream.headers[':status'],'200');
+assert.strictEqual(stream.headers[':status'],200);
 
 awaitPromise.all([stream.closed,serverDone.promise]);
 awaitclientSession.close();

doc/api/quic.md

@@ -3980,8 +3980,9 @@ A few things to note:
  the request is `HEADERS` followed by `END_STREAM`.
 * The `onheaders` callback receives the response pseudo-headers and
  regular headers in a single object with lowercase string keys.
- After the callback returns, the same object is also accessible
- via [`stream.headers`][].
+ For incoming headers, the `:status` pseudo-header is converted to
+ a `number`, matching HTTP/2 behavior. After the callback returns,
+ the same object is also accessible via [`stream.headers`][].
 * Reading `for await (const chunks of stream)` consumes the response
  body. Each iteration yields a `Uint8Array[]` batch of chunks.
 * HTTP semantic helpers (URL parsing, method/status validation,

lib/internal/quic/quic.js

@@ -1285,14 +1285,19 @@ function parseHeaderPairs(pairs) {
 assert(pairs.length%2===0);
 constblock={__proto__: null};
 for(letn=0;n+1<pairs.length;n+=2){
-if(block[pairs[n]]!==undefined){
-if(ArrayIsArray(block[pairs[n]])){
-ArrayPrototypePush(block[pairs[n]],pairs[n+1]);
+constname=pairs[n];
+letvalue=pairs[n+1];
+// Match HTTP/2 behavior: incoming :status is exposed as a number.
+if(name===':status')
+value|=0;
+if(block[name]!==undefined){
+if(ArrayIsArray(block[name])){
+ArrayPrototypePush(block[name],value);
 }else{
-block[pairs[n]]=[block[pairs[n]],pairs[n+1]];
+block[name]=[block[name],value];
 }
 }else{
-block[pairs[n]]=pairs[n+1];
+block[name]=value;
 }
 }
 returnblock;

test/parallel/test-quic-h3-callback-errors.mjs

@@ -151,7 +151,7 @@ async function makeServer(onheadersHandler, extraOpts = {}) {
 ':authority': 'localhost',
 },
 onheaders: mustCall(function(headers){
-assert.strictEqual(headers[':status'],'200');
+assert.strictEqual(headers[':status'],200);
 }),
 ontrailers: mustCall(function(){
 thrownewError('ontrailers sync error');
@@ -265,7 +265,7 @@ async function makeServer(onheadersHandler, extraOpts = {}) {
 ':authority': 'localhost',
 },
 onheaders: mustCall(function(headers){
-assert.strictEqual(headers[':status'],'200');
+assert.strictEqual(headers[':status'],200);
 }),
 });
 

test/parallel/test-quic-h3-close-behavior.mjs

@@ -62,7 +62,7 @@ const decoder = new TextDecoder();
 ':authority': 'localhost',
 },
 onheaders: mustCall((headers)=>{
-assert.strictEqual(headers[':status'],'200');
+assert.strictEqual(headers[':status'],200);
 }),
 });
 
@@ -74,7 +74,7 @@ const decoder = new TextDecoder();
 ':authority': 'localhost',
 },
 onheaders: mustCall((headers)=>{
-assert.strictEqual(headers[':status'],'200');
+assert.strictEqual(headers[':status'],200);
 }),
 });
 

test/parallel/test-quic-h3-concurrent-requests.mjs

@@ -72,7 +72,7 @@ const requests = paths.map(mustCall(async (path) => {
 ':authority': 'localhost',
 },
 onheaders: mustCall((headers)=>{
-assert.strictEqual(headers[':status'],'200');
+assert.strictEqual(headers[':status'],200);
 headersReceived.resolve();
 }),
 });

test/parallel/test-quic-h3-datagram.mjs

@@ -87,7 +87,7 @@ const decoder = new TextDecoder();
 ':authority': 'localhost',
 },
 onheaders: mustCall(function(headers){
-assert.strictEqual(headers[':status'],'200');
+assert.strictEqual(headers[':status'],200);
 }),
 });
 
@@ -151,7 +151,7 @@ const decoder = new TextDecoder();
 ':authority': 'localhost',
 },
 onheaders: mustCall((headers)=>{
-assert.strictEqual(headers[':status'],'200');
+assert.strictEqual(headers[':status'],200);
 }),
 });
 

test/parallel/test-quic-h3-error-codes.mjs

@@ -55,7 +55,7 @@ const decoder = new TextDecoder();
 ':authority': 'localhost',
 },
 onheaders: mustCall(function(headers){
-assert.strictEqual(headers[':status'],'200');
+assert.strictEqual(headers[':status'],200);
 }),
 });
 
@@ -106,7 +106,7 @@ const decoder = new TextDecoder();
 ':authority': 'localhost',
 },
 onheaders: mustCall(function(headers){
-assert.strictEqual(headers[':status'],'200');
+assert.strictEqual(headers[':status'],200);
 }),
 });
 

test/parallel/test-quic-h3-goaway.mjs

@@ -78,7 +78,7 @@ dc.subscribe('quic.session.goaway', mustCall((msg) => {
 awaitclientSession.opened;
 
 constonClientHeaders=mustCall(function(headers){
-assert.strictEqual(headers[':status'],'200');
+assert.strictEqual(headers[':status'],200);
 if(++clientHeaderCount===2){
 bothHeadersReceived.resolve();
 }

test/parallel/test-quic-h3-header-validation.mjs

@@ -91,7 +91,7 @@ const decoder = new TextDecoder();
 },
 onheaders: mustCall(function(headers){
 // Client should also receive lowercased response header names.
-assert.strictEqual(headers[':status'],'200');
+assert.strictEqual(headers[':status'],200);
 assert.strictEqual(headers['content-type'],'text/html');
 assert.strictEqual(headers['x-response-header'],'ResponseValue');
 
@@ -148,7 +148,7 @@ const decoder = new TextDecoder();
 ':authority': 'localhost',
 },
 onheaders: mustCall((headers)=>{
-assert.strictEqual(headers[':status'],'204');
+assert.strictEqual(headers[':status'],204);
 }),
 });
 

test/parallel/test-quic-h3-informational-headers.mjs

@@ -34,7 +34,7 @@ dc.subscribe('quic.stream.info', mustCall((msg) => {
 assert.ok(msg.stream,'stream.info should include stream');
 assert.ok(msg.session,'stream.info should include session');
 assert.ok(msg.headers,'stream.info should include headers');
-assert.strictEqual(msg.headers[':status'],'103');
+assert.strictEqual(msg.headers[':status'],103);
 }));
 
 // quic.stream.headers also fires for the final response headers.
@@ -89,12 +89,12 @@ const stream = await clientSession.createBidirectionalStream({
 ':authority': 'localhost',
 },
 oninfo: mustCall(function(headers){
-assert.strictEqual(headers[':status'],'103');
+assert.strictEqual(headers[':status'],103);
 assert.strictEqual(headers.link,'</style.css>; rel=preload; as=style');
 clientInfoReceived.resolve();
 }),
 onheaders: mustCall(function(headers){
-assert.strictEqual(headers[':status'],'200');
+assert.strictEqual(headers[':status'],200);
 assert.strictEqual(headers['content-type'],'text/plain');
 clientHeadersReceived.resolve();
 }),
@@ -107,7 +107,7 @@ const body = await bytes(stream);
 assert.strictEqual(decoder.decode(body),responseBody);
 
 // stream.headers should return the final (initial) headers, not 1xx.
-assert.strictEqual(stream.headers[':status'],'200');
+assert.strictEqual(stream.headers[':status'],200);
 
 awaitPromise.all([stream.closed,serverDone.promise]);
 awaitclientSession.close();

doc/api/quic.md

@@ -3980,8 +3980,9 @@ A few things to note:
  the request is `HEADERS` followed by `END_STREAM`.
 * The `onheaders` callback receives the response pseudo-headers and
  regular headers in a single object with lowercase string keys.
- After the callback returns, the same object is also accessible
- via [`stream.headers`][].
+ For incoming headers, the `:status` pseudo-header is converted to
+ a `number`, matching HTTP/2 behavior. After the callback returns,
+ the same object is also accessible via [`stream.headers`][].
 * Reading `for await (const chunks of stream)` consumes the response
  body. Each iteration yields a `Uint8Array[]` batch of chunks.
 * HTTP semantic helpers (URL parsing, method/status validation,

lib/internal/quic/quic.js

@@ -1285,14 +1285,19 @@ function parseHeaderPairs(pairs) {
 assert(pairs.length%2===0);
 constblock={__proto__: null};
 for(letn=0;n+1<pairs.length;n+=2){
-if(block[pairs[n]]!==undefined){
-if(ArrayIsArray(block[pairs[n]])){
-ArrayPrototypePush(block[pairs[n]],pairs[n+1]);
+constname=pairs[n];
+letvalue=pairs[n+1];
+// Match HTTP/2 behavior: incoming :status is exposed as a number.
+if(name===':status')
+value|=0;
+if(block[name]!==undefined){
+if(ArrayIsArray(block[name])){
+ArrayPrototypePush(block[name],value);
 }else{
-block[pairs[n]]=[block[pairs[n]],pairs[n+1]];
+block[name]=[block[name],value];
 }
 }else{
-block[pairs[n]]=pairs[n+1];
+block[name]=value;
 }
 }
 returnblock;

test/parallel/test-quic-h3-callback-errors.mjs

@@ -151,7 +151,7 @@ async function makeServer(onheadersHandler, extraOpts = {}) {
 ':authority': 'localhost',
 },
 onheaders: mustCall(function(headers){
-assert.strictEqual(headers[':status'],'200');
+assert.strictEqual(headers[':status'],200);
 }),
 ontrailers: mustCall(function(){
 thrownewError('ontrailers sync error');
@@ -265,7 +265,7 @@ async function makeServer(onheadersHandler, extraOpts = {}) {
 ':authority': 'localhost',
 },
 onheaders: mustCall(function(headers){
-assert.strictEqual(headers[':status'],'200');
+assert.strictEqual(headers[':status'],200);
 }),
 });
 

test/parallel/test-quic-h3-close-behavior.mjs

@@ -62,7 +62,7 @@ const decoder = new TextDecoder();
 ':authority': 'localhost',
 },
 onheaders: mustCall((headers)=>{
-assert.strictEqual(headers[':status'],'200');
+assert.strictEqual(headers[':status'],200);
 }),
 });
 
@@ -74,7 +74,7 @@ const decoder = new TextDecoder();
 ':authority': 'localhost',
 },
 onheaders: mustCall((headers)=>{
-assert.strictEqual(headers[':status'],'200');
+assert.strictEqual(headers[':status'],200);
 }),
 });
 

test/parallel/test-quic-h3-concurrent-requests.mjs

@@ -72,7 +72,7 @@ const requests = paths.map(mustCall(async (path) => {
 ':authority': 'localhost',
 },
 onheaders: mustCall((headers)=>{
-assert.strictEqual(headers[':status'],'200');
+assert.strictEqual(headers[':status'],200);
 headersReceived.resolve();
 }),
 });

test/parallel/test-quic-h3-datagram.mjs

@@ -87,7 +87,7 @@ const decoder = new TextDecoder();
 ':authority': 'localhost',
 },
 onheaders: mustCall(function(headers){
-assert.strictEqual(headers[':status'],'200');
+assert.strictEqual(headers[':status'],200);
 }),
 });
 
@@ -151,7 +151,7 @@ const decoder = new TextDecoder();
 ':authority': 'localhost',
 },
 onheaders: mustCall((headers)=>{
-assert.strictEqual(headers[':status'],'200');
+assert.strictEqual(headers[':status'],200);
 }),
 });
 

test/parallel/test-quic-h3-error-codes.mjs

@@ -55,7 +55,7 @@ const decoder = new TextDecoder();
 ':authority': 'localhost',
 },
 onheaders: mustCall(function(headers){
-assert.strictEqual(headers[':status'],'200');
+assert.strictEqual(headers[':status'],200);
 }),
 });
 
@@ -106,7 +106,7 @@ const decoder = new TextDecoder();
 ':authority': 'localhost',
 },
 onheaders: mustCall(function(headers){
-assert.strictEqual(headers[':status'],'200');
+assert.strictEqual(headers[':status'],200);
 }),
 });
 

test/parallel/test-quic-h3-goaway.mjs

@@ -78,7 +78,7 @@ dc.subscribe('quic.session.goaway', mustCall((msg) => {
 awaitclientSession.opened;
 
 constonClientHeaders=mustCall(function(headers){
-assert.strictEqual(headers[':status'],'200');
+assert.strictEqual(headers[':status'],200);
 if(++clientHeaderCount===2){
 bothHeadersReceived.resolve();
 }

test/parallel/test-quic-h3-header-validation.mjs

@@ -91,7 +91,7 @@ const decoder = new TextDecoder();
 },
 onheaders: mustCall(function(headers){
 // Client should also receive lowercased response header names.
-assert.strictEqual(headers[':status'],'200');
+assert.strictEqual(headers[':status'],200);
 assert.strictEqual(headers['content-type'],'text/html');
 assert.strictEqual(headers['x-response-header'],'ResponseValue');
 
@@ -148,7 +148,7 @@ const decoder = new TextDecoder();
 ':authority': 'localhost',
 },
 onheaders: mustCall((headers)=>{
-assert.strictEqual(headers[':status'],'204');
+assert.strictEqual(headers[':status'],204);
 }),
 });
 

test/parallel/test-quic-h3-informational-headers.mjs

@@ -34,7 +34,7 @@ dc.subscribe('quic.stream.info', mustCall((msg) => {
 assert.ok(msg.stream,'stream.info should include stream');
 assert.ok(msg.session,'stream.info should include session');
 assert.ok(msg.headers,'stream.info should include headers');
-assert.strictEqual(msg.headers[':status'],'103');
+assert.strictEqual(msg.headers[':status'],103);
 }));
 
 // quic.stream.headers also fires for the final response headers.
@@ -89,12 +89,12 @@ const stream = await clientSession.createBidirectionalStream({
 ':authority': 'localhost',
 },
 oninfo: mustCall(function(headers){
-assert.strictEqual(headers[':status'],'103');
+assert.strictEqual(headers[':status'],103);
 assert.strictEqual(headers.link,'</style.css>; rel=preload; as=style');
 clientInfoReceived.resolve();
 }),
 onheaders: mustCall(function(headers){
-assert.strictEqual(headers[':status'],'200');
+assert.strictEqual(headers[':status'],200);
 assert.strictEqual(headers['content-type'],'text/plain');
 clientHeadersReceived.resolve();
 }),
@@ -107,7 +107,7 @@ const body = await bytes(stream);
 assert.strictEqual(decoder.decode(body),responseBody);
 
 // stream.headers should return the final (initial) headers, not 1xx.
-assert.strictEqual(stream.headers[':status'],'200');
+assert.strictEqual(stream.headers[':status'],200);
 
 awaitPromise.all([stream.closed,serverDone.promise]);
 awaitclientSession.close();