Remove ttype

test/node-test/abort-event-emitter.js

@@ -8,7 +8,6 @@ const { createReadStream } = require('fs')
 const { Readable } = require('stream')
 const { tspl } = require('@matteo.collina/tspl')
 const { wrapWithAsyncIterable } = require('../utils/async-iterators')
-const { ttype } = require('../utils/node-test')
 
 test('Abort before sending request (no body)', async (t) => {
   const p = tspl(t, { plan: 4 })
@@ -42,15 +41,15 @@ test('Abort before sending request (no body)', async (t) => {
 
     const body = new Readable({ read () { } })
     body.on('error', (err) => {
-      p.ok(ttype(err, errors.RequestAbortedError))
+      p.ok(err instanceof errors.RequestAbortedError)
     })
     client.request({
       path: '/',
       method: 'GET',
       signal: ee,
       body
     }, (err, response) => {
-      p.ok(ttype(err, errors.RequestAbortedError))
+      p.ok(err instanceof errors.RequestAbortedError)
     })
 
     ee.emit('abort')
@@ -96,7 +95,7 @@ test('Abort before sending request (no body) async iterator', async (t) => {
       signal: ee,
       body
     }, (err, response) => {
-      p.ok(ttype(err, errors.RequestAbortedError))
+      p.ok(err instanceof errors.RequestAbortedError)
     })
 
     ee.emit('abort')
@@ -121,7 +120,7 @@ test('Abort while waiting response (no body)', async (t) => {
     t.after(client.destroy.bind(client))
 
     client.request({ path: '/', method: 'GET', signal: ee }, (err, response) => {
-      p.ok(ttype(err, errors.RequestAbortedError))
+      p.ok(err instanceof errors.RequestAbortedError)
     })
   })
 
@@ -145,7 +144,7 @@ test('Abort while waiting response (write headers started) (no body)', async (t)
     t.after(client.destroy.bind(client))
 
     client.request({ path: '/', method: 'GET', signal: ee }, (err, response) => {
-      p.ok(ttype(err, errors.RequestAbortedError))
+      p.ok(err instanceof errors.RequestAbortedError)
     })
   })
 
@@ -172,7 +171,7 @@ test('Abort while waiting response (write headers and write body started) (no bo
         ee.emit('abort')
       })
       response.body.on('error', err => {
-        p.ok(ttype(err, errors.RequestAbortedError))
+        p.ok(err instanceof errors.RequestAbortedError)
       })
     })
   })
@@ -196,7 +195,7 @@ function waitingWithBody (body, type) {
       t.after(client.destroy.bind(client))
 
       client.request({ path: '/', method: 'POST', body, signal: ee }, (err, response) => {
-        p.ok(ttype(err, errors.RequestAbortedError))
+        p.ok(err instanceof errors.RequestAbortedError)
       })
     })
     await p.completed
@@ -226,7 +225,7 @@ function writeHeadersStartedWithBody (body, type) {
       t.after(client.destroy.bind(client))
 
       client.request({ path: '/', method: 'POST', body, signal: ee }, (err, response) => {
-        p.ok(ttype(err, errors.RequestAbortedError))
+        p.ok(err instanceof errors.RequestAbortedError)
       })
     })
     await p.completed
@@ -259,7 +258,7 @@ function writeBodyStartedWithBody (body, type) {
           ee.emit('abort')
         })
         response.body.on('error', err => {
-          p.ok(ttype(err, errors.RequestAbortedError))
+          p.ok(err instanceof errors.RequestAbortedError)
         })
       })
     })