fixed a responseType stream called and endpoint...

tests/http/http-timeout.test.js

@@ -1,6 +1,7 @@
+const axios = require('axios')
 const {jsonClient} = global.t
 
-test('basic http test', async () => {
+test('timeout is too short', async () => {
   const {post} = jsonClient({timeout: 100})
   await expect(post('/long', {})).rejects.toMatchObject({
     code: 'ETIMEDOUT',
@@ -14,3 +15,19 @@ test('timeout is ok', async () => {
   const {status} = await jsonClient({timeout: 500}).post('/long', {})
   expect(status).toEqual(200)
 })
+
+test('short timeout with response stream', async () => {
+  const {post} = jsonClient({timeout: 100, responseType: 'stream'})
+  await expect(post('/stream', {})).rejects.toMatchObject({
+    code: 'ETIMEDOUT',
+    timeout: 100,
+    status: 408,
+    message: 'Timed out.',
+  })
+})
+
+test.only('wait', async () => {
+  const {post} = jsonClient({timeout: 500, responseType: 'stream'})
+  const {status} = await post('/stream', {})
+  expect(status).toEqual(201)
+})

tests/http/routes.js

@@ -21,7 +21,6 @@ module.exports = app => {
   })
 
   app.get('/booom', () => {
-    // console.log(request.headers)
     // eslint-disable-next-line fp/no-throw
     throw new Error('big booom')
   })
@@ -37,10 +36,22 @@ module.exports = app => {
   })
 
   app.post('/long', async () => {
+    // console.log('Called...')
     await sleep(400)
     return {slow: true}
   })
 
+  app.post('/stream', async (request, reply) => {
+    reply.raw.setHeader('transfer-encoding', 'chunked')
+    reply.code(201)
+    // reply.hijack()
+    // console.log('Stream started...')
+    await sleep(400)
+    reply.raw.write('new line...')
+    // console.log('Stream finished.')
+    reply.raw.end()
+  })
+
   app.get('/async-pipe-booom', async (request, reply) => {
     await __([1])
       // eslint-disable-next-line require-await