Diffusion SHRINE MedCo Fork (feature/i2b2-merge-to-develop) Browse

shrine-medco/shrine-webclient/src/main/html/node_modules/multipipe/test/multipipe.js
f571d119036dfeature/i2b2-merge-to…

multipipe.js
View Options

			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;
			}