Function socketFailEndWrite

test/node-test/client-errors.js:1007–1050

(type)

socketFailWrite(consts.ASYNC_ITERATOR)

function socketFailEndWrite (type) {
  test(`socket fail while ending ${type} request body`, async (t) => {
    const p = tspl(t, { plan: 3 })

    const server = createServer({ joinDuplicateHeaders: true })
    server.once('request', (req, res) => {
      res.end()
    })
    t.after(closeServerAsPromise(server))

    server.listen(0, () => {
      const client = new Client(`http://localhost:${server.address().port}`, {
        pipelining: 2
      })
      t.after(client.destroy.bind(client))

      const _err = new Error('kaboom')
      client.on('connect', () => {
        process.nextTick(() => {
          client[kSocket].destroy(_err)
        })
      })
      const preBody = new Readable({ read () {} })
      preBody.push(null)
      const body = maybeWrapStream(preBody, type)

      client.request({
        path: '/',
        method: 'POST',
        body
      }, (err) => {
        p.strictEqual(err, _err)
      })
      client.close((err) => {
        p.ifError(err)
        client.close((err) => {
          p.ok(err instanceof errors.ClientDestroyedError)
        })
      })
    })

    await p.completed
  })
}

socketFailEndWrite(consts.STREAM)
socketFailEndWrite(consts.ASYNC_ITERATOR)