Add tests for request with stream

ROAD_MAP.md

@@ -1,11 +1,9 @@
 # ROADMAP
-- Create your on invirte module
 - configuration for each plugin
 - Informative README stage 2 (english improvement)
-- check the library with streaming
 - Cdn implementation
-
-
+- Create your on invirte module
+- cancel open group
 
 Options
 ----

server/index.js

@@ -35,9 +35,14 @@ app.get('/basic', basicResponse)
 
 app.post('/multipart', (req, res) => res.sendStatus(200))
 
+app.get('/stream', (req, res) => {
+  res.write("USERID,NAME,FBID,ACCOUNT,SUBSCRIPTION,PRICE,STATE,TIMEPERIOD\n")
+  res.write("23,John Doe,1234,500,SUBSCRIPITON,100,ACTIVE,30\n")
+  res.end()
+})
 
-let server
 
+let server
 module.exports = {
   init: () => {
     server = app.listen(port)

test/log/index.spec.js

@@ -256,4 +256,12 @@ describe('Log plugin', () => {
       assert.isTrue(printedData.requestData.data._valuesToMeasure[0].path === absolutePath)
     })
   })
+
+  context('is plugin work well with streams', () => {
+    it('should print stream request', async () => {
+      await axios.get(`${BASIC_URL}/stream`)
+      const printedData = consoleLogSpy.lastCall.args[0]
+      assert.isTrue(printedData.url === `${BASIC_URL}/stream`)
+    })
+  })
 })

test/pending/index.spec.js

@@ -84,4 +84,15 @@ describe('Pending plugin', () => {
       })
     })
   })
+
+  context('is plugin work well with streams', () => {
+     it('should save pending stream requests', done => {
+       axios.get(`${BASIC_URL}/stream`).then(() => {
+         done()
+       })
+       setImmediate(() => {
+         assert.isTrue(Redel.getPendingRequests().length === 1)
+       })
+     })
+  })
 })