aboutsummaryrefslogtreecommitdiff
path: root/node_modules/multipipe/test/multipipe.js
diff options
context:
space:
mode:
Diffstat (limited to 'node_modules/multipipe/test/multipipe.js')
-rw-r--r--node_modules/multipipe/test/multipipe.js141
1 files changed, 0 insertions, 141 deletions
diff --git a/node_modules/multipipe/test/multipipe.js b/node_modules/multipipe/test/multipipe.js
deleted file mode 100644
index 078d2e031..000000000
--- a/node_modules/multipipe/test/multipipe.js
+++ /dev/null
@@ -1,141 +0,0 @@
-var assert = require('assert');
-var pipe = require('..');
-var Stream = require('stream');
-
-describe('pipe(a)', function(){
- it('should return a', function(){
- var readable = Readable();
- var stream = pipe(readable);
- assert.equal(stream, readable);
- });
-});
-
-describe('pipe(a, b, c)', function(){
- it('should pipe internally', function(done){
- pipe(Readable(), Transform(), Writable(done));
- });
-
- it('should be writable', function(done){
- var stream = pipe(Transform(), Writable(done));
- assert(stream.writable);
- Readable().pipe(stream);
- });
-
- it('should be readable', function(done){
- var stream = pipe(Readable(), Transform());
- assert(stream.readable);
- stream.pipe(Writable(done));
- });
-
- it('should be readable and writable', function(done){
- var stream = pipe(Transform(), Transform());
- assert(stream.readable);
- assert(stream.writable);
- Readable()
- .pipe(stream)
- .pipe(Writable(done));
- });
-
- describe('errors', function(){
- it('should reemit', function(done){
- var a = Transform();
- var b = Transform();
- var c = Transform();
- var stream = pipe(a, b, c);
- var err = new Error;
- var i = 0;
-
- stream.on('error', function(_err){
- i++;
- assert.equal(_err, err);
- assert(i <= 3);
- if (i == 3) done();
- });
-
- a.emit('error', err);
- b.emit('error', err);
- c.emit('error', err);
- });
-
- it('should not reemit endlessly', function(done){
- var a = Transform();
- var b = Transform();
- var c = Transform();
- c.readable = false;
- var stream = pipe(a, b, c);
- var err = new Error;
- var i = 0;
-
- stream.on('error', function(_err){
- i++;
- assert.equal(_err, err);
- assert(i <= 3);
- if (i == 3) done();
- });
-
- a.emit('error', err);
- b.emit('error', err);
- c.emit('error', err);
- });
- });
-});
-
-describe('pipe(a, b, c, fn)', function(){
- it('should call on finish', function(done){
- var finished = false;
- var a = Readable();
- var b = Transform();
- var c = Writable(function(){
- finished = true;
- });
-
- pipe(a, b, c, function(err){
- assert(!err);
- assert(finished);
- done();
- });
- });
-
- it('should call with error once', function(done){
- var a = Readable();
- var b = Transform();
- var c = Writable();
- var err = new Error;
-
- pipe(a, b, c, function(err){
- assert(err);
- done();
- });
-
- a.emit('error', err);
- b.emit('error', err);
- c.emit('error', err);
- });
-});
-
-function Readable(){
- var readable = new Stream.Readable({ objectMode: true });
- readable._read = function(){
- this.push('a');
- this.push(null);
- };
- return readable;
-}
-
-function Transform(){
- var transform = new Stream.Transform({ objectMode: true });
- transform._transform = function(chunk, _, done){
- done(null, chunk.toUpperCase());
- };
- return transform;
-}
-
-function Writable(cb){
- var writable = new Stream.Writable({ objectMode: true });
- writable._write = function(chunk, _, done){
- assert.equal(chunk, 'A');
- done();
- cb();
- };
- return writable;
-}