Function onClientStreamFinish

lib/internal/inspector/network_http2.js:193–231

* When response headers are received, emit Network.responseReceived event. * https://chromedevtools.github.io/devtools-protocol/1-3/Network/#event-responseReceived * @param {{ stream: import('http2').ClientHttp2Stream, headers: object }} event

({ stream, headers })

 * @param {{ stream: import('http2').ClientHttp2Stream, headers: object }} event
 */
function onClientStreamFinish({ stream, headers }) {
  if (typeof stream[kInspectorRequestId] !== 'string') {
    return;
  }

  const { 0: convertedHeaderObject, 3: statusCode, 4: charset, 5: mimeType } = convertHeaderObject(headers);

  Network.responseReceived({
    requestId: stream[kInspectorRequestId],
    timestamp: getMonotonicTime(),
    type: kResourceType.Other,
    response: {
      url: stream[kRequestUrl],
      status: statusCode,
      statusText: '',
      headers: convertedHeaderObject,
      mimeType,
      charset,
    },
  });

  // Unlike stream.on('data', ...), this does not put the stream into flowing mode.
  EventEmitter.prototype.on.call(stream, 'data', (chunk) => {
    /**
     * When a chunk of the response body has been received, cache it until `getResponseBody` request
     * https://chromedevtools.github.io/devtools-protocol/1-3/Network/#method-getResponseBody or
     * stream it with `streamResourceContent` request.
     * https://chromedevtools.github.io/devtools-protocol/tot/Network/#method-streamResourceContent
     */

    Network.dataReceived({
      requestId: stream[kInspectorRequestId],
      timestamp: getMonotonicTime(),
      dataLength: chunk.byteLength,
      encodedDataLength: chunk.byteLength,
      data: chunk,
    });
  });
}

/**
 * When user code completes consuming the response body, emit Network.loadingFinished event.