Function socketFailWrite

test/node-test/client-errors.js:1115–1151

(type)

})

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

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

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

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

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

    await p.completed
  })
}
socketFailWrite(consts.STREAM)
socketFailWrite(consts.ASYNC_ITERATOR)