req.write = function()

in src/ResponseStream.js [224:259]

• 29 lines of code
• 7 McCabe index (conditional complexity)

  req.write = function (chunk, encoding, callback) {
    vvverbose(
      'ResponseStream::write',
      chunk.length,
      'callback:',
      typeof callback,
    );

    if (
      typeof chunk !== 'string' &&
      !Buffer.isBuffer(chunk) &&
      chunk?.constructor !== Uint8Array
    ) {
      chunk = JSON.stringify(chunk);
    }

    if (
      status === STATUS_READY &&
      typeof this._onBeforeFirstWrite === 'function'
    ) {
      this._onBeforeFirstWrite((ch) => origWrite(ch));
    }

    // First write shall open the connection.
    const ret = origWrite(chunk, encoding, callback);

    vvverbose('ResponseStream::origWrite', ret);
    vvverbose('ResponseStream::write outputData len', this.outputData.length);
    vvverbose('ResponseStream::write outputSize', this.outputSize);

    if (status === STATUS_READY) {
      status = STATUS_WRITE_CALLED;
    }

    return ret;
  };