http2: emit timeout on compat request and response

lib/internal/http2/compat.js

@@ -243,6 +243,13 @@ function onStreamCloseRequest() {
  req.emit('close');
 }
 
+function onStreamTimeout(kind) {
+ return function onStreamTimeout() {
+ const obj = this[kind];
+ obj.emit('timeout');
+ };
+}
+
 class Http2ServerRequest extends Readable {
  constructor(stream, headers, options, rawHeaders) {
  super(options);
@@ -265,6 +272,7 @@ class Http2ServerRequest extends Readable {
  stream.on('error', onStreamError);
  stream.on('aborted', onStreamAbortedRequest);
  stream.on('close', onStreamCloseRequest);
+ stream.on('timeout', onStreamTimeout(kRequest));
  this.on('pause', onRequestPause);
  this.on('resume', onRequestResume);
  }
@@ -418,6 +426,7 @@ class Http2ServerResponse extends Stream {
  stream.on('aborted', onStreamAbortedResponse);
  stream.on('close', onStreamCloseResponse);
  stream.on('wantTrailers', onStreamTrailersReady);
+ stream.on('timeout', onStreamTimeout(kResponse));
  }
 
  // User land modules such as finalhandler just check truthiness of this

test/parallel/test-http2-compat-serverrequest-settimeout.js

@@ -12,6 +12,7 @@ server.on('request', (req, res) => {
  req.setTimeout(msecs, common.mustCall(() => {
  res.end();
  }));
+ req.on('timeout', common.mustCall());
  res.on('finish', common.mustCall(() => {
  req.setTimeout(msecs, common.mustNotCall());
  process.nextTick(() => {

test/parallel/test-http2-compat-serverresponse-settimeout.js

@@ -12,6 +12,7 @@ server.on('request', (req, res) => {
  res.setTimeout(msecs, common.mustCall(() => {
  res.end();
  }));
+ res.on('timeout', common.mustCall());
  res.on('finish', common.mustCall(() => {
  res.setTimeout(msecs, common.mustNotCall());
  process.nextTick(() => {