tests: use Verify() with streams3 tests

Refs: #34 PR-URL: #35
Fishrock123 · Jul 16, 2019 · 0fe264f · 0fe264f
1 parent 9b6d3ae
commit 0fe264f
Show file tree

Hide file tree

Showing 4 changed files with 16 additions and 7 deletions.
diff --git a/tests/test-streams3-from-source.js b/tests/test-streams3-from-source.js
@@ -4,8 +4,10 @@ const tap = require('tap')
 const fs = require('fs')
 const path = require('path')
 
+const Stream = require('../helpers/stream')
 const AssertionSource = require('./helpers/assertion-source')
 const BobDuplex = require('../helpers/bob-duplex')
+const Verify = require('../reference-verify')
 
 tap.test('test streams3 (BobDuplex) from a source', t => {
   t.plan(2)
@@ -28,6 +30,8 @@ tap.test('test streams3 (BobDuplex) from a source', t => {
   const ws = fs.createWriteStream(filename, { highWaterMark: 1024 })
   const bobDuplex = new BobDuplex({ highWaterMark: 1024, name: '1' })
 
+  new Stream(source, new Verify(), bobDuplex) // eslint-disable-line no-new
+
   bobDuplex.bindSource(source)
   bobDuplex.pipe(ws)
 

diff --git a/tests/test-streams3-to-sink.js b/tests/test-streams3-to-sink.js
@@ -4,8 +4,10 @@ const tap = require('tap')
 const fs = require('fs')
 const path = require('path')
 
+const Stream = require('../helpers/stream')
 const AssertionSink = require('./helpers/assertion-sink')
 const BobDuplex = require('../helpers/bob-duplex')
+const Verify = require('../reference-verify')
 
 tap.test('test streams3 (BobDuplex) to a sink', t => {
   t.plan(1)
@@ -23,7 +25,8 @@ tap.test('test streams3 (BobDuplex) to a sink', t => {
   rs.pipe(bobDuplex)
   rs.on('error', error => t.fail('ReadStream error', error))
 
-  sink.bindSource(bobDuplex).start(error => {
+  const stream = new Stream(bobDuplex, new Verify(), sink)
+  stream.start(error => {
     t.error(error, 'Exit Callback received unexpected error')
     t.end()
   })

diff --git a/tests/test-streams3-zlib.js b/tests/test-streams3-zlib.js
@@ -3,10 +3,11 @@
 const tap = require('tap')
 const zlib = require('zlib')
 
+const Stream = require('../helpers/stream')
 const AssertionSource = require('./helpers/assertion-source')
 const AssertionSink = require('./helpers/assertion-sink')
-const Stream = require('../helpers/stream')
 const BobDuplex = require('../helpers/bob-duplex')
+const Verify = require('../reference-verify')
 
 tap.test('test streams3 (BobDuplex) with a Transform', t => {
   t.plan(1)
@@ -29,8 +30,8 @@ tap.test('test streams3 (BobDuplex) with a Transform', t => {
   const bobDuplex1 = new BobDuplex({ highWaterMark: 1024, name: '1' })
   const bobDuplex2 = new BobDuplex({ highWaterMark: 1024, name: '2' })
 
-  const stream1 = new Stream(source, bobDuplex1) // eslint-disable-line no-unused-vars
-  const stream2 = new Stream(bobDuplex2, sink)
+  const stream1 = new Stream(source, new Verify(), bobDuplex1) // eslint-disable-line no-unused-vars
+  const stream2 = new Stream(bobDuplex2, new Verify(), sink)
 
   const gzip = zlib.createGzip()
   gzip.on('error', error => t.fail('GZIP error', error))

diff --git a/tests/test-streams3.js b/tests/test-streams3.js
@@ -2,10 +2,11 @@
 
 const tap = require('tap')
 
+const Stream = require('../helpers/stream')
 const AssertionSource = require('./helpers/assertion-source')
 const AssertionSink = require('./helpers/assertion-sink')
-const Stream = require('../helpers/stream')
 const BobDuplex = require('../helpers/bob-duplex')
+const Verify = require('../reference-verify')
 
 tap.test('test streams3 adaptor (BobDuplex)', t => {
   t.plan(1)
@@ -23,8 +24,8 @@ tap.test('test streams3 adaptor (BobDuplex)', t => {
   const bobDuplex1 = new BobDuplex({ highWaterMark: 6, name: '1' })
   const bobDuplex2 = new BobDuplex({ highWaterMark: 6, name: '2' })
 
-  const stream1 = new Stream(source, bobDuplex1) // eslint-disable-line no-unused-vars
-  const stream2 = new Stream(bobDuplex2, sink)
+  const stream1 = new Stream(source, new Verify(), bobDuplex1) // eslint-disable-line no-unused-vars
+  const stream2 = new Stream(bobDuplex2, new Verify(), sink)
 
   bobDuplex1.pipe(bobDuplex2)