aboutsummaryrefslogtreecommitdiff
path: root/node_modules/stream-consume
diff options
context:
space:
mode:
authorFlorian Dold <florian.dold@gmail.com>2018-09-20 02:56:13 +0200
committerFlorian Dold <florian.dold@gmail.com>2018-09-20 02:56:13 +0200
commitbbff7403fbf46f9ad92240ac213df8d30ef31b64 (patch)
treec58400ec5124da1c7d56b01aea83309f80a56c3b /node_modules/stream-consume
parent003fb34971cf63466184351b4db5f7c67df4f444 (diff)
update packages
Diffstat (limited to 'node_modules/stream-consume')
-rw-r--r--node_modules/stream-consume/.npmignore1
-rw-r--r--node_modules/stream-consume/package.json2
-rw-r--r--node_modules/stream-consume/test/tests.js180
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");
- });
-
-});