diff options
author | Florian Dold <florian.dold@gmail.com> | 2018-09-20 02:56:13 +0200 |
---|---|---|
committer | Florian Dold <florian.dold@gmail.com> | 2018-09-20 02:56:13 +0200 |
commit | bbff7403fbf46f9ad92240ac213df8d30ef31b64 (patch) | |
tree | c58400ec5124da1c7d56b01aea83309f80a56c3b /node_modules/stream-consume | |
parent | 003fb34971cf63466184351b4db5f7c67df4f444 (diff) |
update packages
Diffstat (limited to 'node_modules/stream-consume')
-rw-r--r-- | node_modules/stream-consume/.npmignore | 1 | ||||
-rw-r--r-- | node_modules/stream-consume/package.json | 2 | ||||
-rw-r--r-- | node_modules/stream-consume/test/tests.js | 180 |
3 files changed, 1 insertions, 182 deletions
diff --git a/node_modules/stream-consume/.npmignore b/node_modules/stream-consume/.npmignore deleted file mode 100644 index 3c3629e64..000000000 --- a/node_modules/stream-consume/.npmignore +++ /dev/null @@ -1 +0,0 @@ -node_modules diff --git a/node_modules/stream-consume/package.json b/node_modules/stream-consume/package.json index f887e17e7..9d601be52 100644 --- a/node_modules/stream-consume/package.json +++ b/node_modules/stream-consume/package.json @@ -1,6 +1,6 @@ { "name": "stream-consume", - "version": "0.1.0", + "version": "0.1.1", "description": "Consume a stream to ensure it keeps flowing", "main": "index.js", "scripts": { diff --git a/node_modules/stream-consume/test/tests.js b/node_modules/stream-consume/test/tests.js deleted file mode 100644 index 660e37a11..000000000 --- a/node_modules/stream-consume/test/tests.js +++ /dev/null @@ -1,180 +0,0 @@ -/*jshint node:true */ -/*global describe:false, it:false */ -"use strict"; - -var consume = require('../'); -var Stream = require('stream'); -var Readable = Stream.Readable; -var Writable = Stream.Writable; -var Duplex = Stream.Duplex; -var should = require('should'); -var through = require('through2'); -require('mocha'); - -describe('stream-consume', function() { - - it('should cause a Readable stream to complete if it\'s not piped anywhere', function(done) { - var rs = new Readable({highWaterMark: 2}); - var a = 0; - var ended = false; - rs._read = function() { - if (a++ < 100) { - rs.push(a + ""); - } else { - ended = true; - rs.push(null); - } - }; - - rs.on("end", function() { - a.should.be.above(99); - ended.should.be.true; - done(); - }); - - consume(rs); - }); - - it('should work with Readable streams in objectMode', function(done) { - var rs = new Readable({highWaterMark: 2, objectMode: true}); - var a = 0; - var ended = false; - rs._read = function() { - if (a++ < 100) { - rs.push(a); - } else { - ended = true; - rs.push(null); - } - }; - - rs.on("end", function() { - a.should.be.above(99); - ended.should.be.true; - done(); - }); - - consume(rs); - }); - - it('should not interfere with a Readable stream that is piped somewhere', function(done) { - var rs = new Readable({highWaterMark: 2}); - var a = 0; - var ended = false; - rs._read = function() { - if (a++ < 100) { - rs.push("."); - } else { - ended = true; - rs.push(null); - } - }; - - var sizeRead = 0; - var ws = new Writable({highWaterMark: 2}); - ws._write = function(chunk, enc, next) { - sizeRead += chunk.length; - next(); - } - - ws.on("finish", function() { - a.should.be.above(99); - ended.should.be.true; - sizeRead.should.equal(100); - done(); - }); - - rs.pipe(ws); - - consume(rs); - }); - - it('should not interfere with a Writable stream', function(done) { - var rs = new Readable({highWaterMark: 2}); - var a = 0; - var ended = false; - rs._read = function() { - if (a++ < 100) { - rs.push("."); - } else { - ended = true; - rs.push(null); - } - }; - - var sizeRead = 0; - var ws = new Writable({highWaterMark: 2}); - ws._write = function(chunk, enc, next) { - sizeRead += chunk.length; - next(); - } - - ws.on("finish", function() { - a.should.be.above(99); - ended.should.be.true; - sizeRead.should.equal(100); - done(); - }); - - rs.pipe(ws); - - consume(ws); - }); - - it('should handle a Transform stream', function(done) { - var rs = new Readable({highWaterMark: 2}); - var a = 0; - var ended = false; - rs._read = function() { - if (a++ < 100) { - rs.push("."); - } else { - ended = true; - rs.push(null); - } - }; - - var sizeRead = 0; - var flushed = false; - var ts = through({highWaterMark: 2}, function(chunk, enc, cb) { - sizeRead += chunk.length; - this.push(chunk); - cb(); - }, function(cb) { - flushed = true; - cb(); - }); - - ts.on("end", function() { - a.should.be.above(99); - ended.should.be.true; - sizeRead.should.equal(100); - flushed.should.be.true; - done(); - }); - - rs.pipe(ts); - - consume(ts); - }); - - it('should handle a classic stream', function(done) { - var rs = new Stream(); - var ended = false; - var i; - - rs.on("end", function() { - ended.should.be.true; - done(); - }); - - consume(rs); - - for (i = 0; i < 100; i++) { - rs.emit("data", i); - } - ended = true; - rs.emit("end"); - }); - -}); |