Function continueWithResponseBody

lib/playback_interceptor.js:254–291

(
    rawBody,
    fullResponseStatus,
    fullResponseRawHeaders = [],
  )

  }

  async function continueWithResponseBody(
    rawBody,
    fullResponseStatus,
    fullResponseRawHeaders = [],
  ) {
    const headers = await prepareResponseHeaders(
      rawBody,
      fullResponseRawHeaders,
    )
    const bodyAsStream = convertBodyToStream(rawBody)
    bodyAsStream.resume()

    // TODO: there is probably a better way to support delay.
    // Wrap the stream in a duplex stream to support the delay.
    const readable = new stream.Readable({
      read() {},
    })
    bodyAsStream.on('data', function (chunk) {
      readable.push(chunk)
    })
    bodyAsStream.on('end', function () {
      common.setTimeout(() => {
        readable.push(null)
        interceptor.scope.emit('replied', decompressedRequest, interceptor)
      }, interceptor.delayBodyInMs)
    })
    bodyAsStream.on('error', function (err) {
      readable.emit('error', err)
    })

    const status = interceptor.statusCode || fullResponseStatus
    const hasBody = FetchResponse.isResponseWithBody(status)
    return new Response(hasBody ? readable : null, {
      status,
      statusText: STATUS_CODES[status],
      headers,
    })
  }
}

module.exports = { playbackInterceptor }