diff options
Diffstat (limited to 'node_modules/gulp-stream/test')
| -rw-r--r-- | node_modules/gulp-stream/test/gulp-stream.js | 105 | 
1 files changed, 0 insertions, 105 deletions
| diff --git a/node_modules/gulp-stream/test/gulp-stream.js b/node_modules/gulp-stream/test/gulp-stream.js deleted file mode 100644 index fc38f0ad2..000000000 --- a/node_modules/gulp-stream/test/gulp-stream.js +++ /dev/null @@ -1,105 +0,0 @@ -var fs = require('fs'); -var File = require('vinyl'); -var buffer = require('..'); -var through = require('through2'); -var assert = require('assert'); -var Stream = require('stream'); - -describe('gulp-buffer', function() { - -  describe('with null contents', function() {  -    it('should let null files pass through', function(done) { -      var b = buffer(); -      var n = 0; -      var _transform = function(file, enc, callback) { -        assert.equal(file.contents, null); -        n++; -	callback(); -      } -      var _flush = function(callback) { -        assert.equal(n, 1); -        done(); -	callback(); -      } -      var t = through.obj(_transform, _flush); -      b.pipe(t); -      b.end(new File({ -        contents: null -      })); -    }); -  }); - -  describe('with stream contents', function() {  -    it('should let stream files pass through', function(done) { -      var b = buffer(); -      var n = 0; -      var c = Readable(); -      var _transform = function(file, enc, callback) { -        assert.equal(file.contents, c); -        n++; -	callback(); -      } -      var _flush = function(callback) { -        assert.equal(n, 1); -        done(); -	callback(); -      } -      var t = through.obj(_transform, _flush); -      b.pipe(t); -      b.end(new File({ -        contents: c -      })); -    }); -  }); - -  describe('with buffer contents', function() {  -    it('should transform stream to buffer', function(done) { -      var b = buffer(); -      var n = 0; -      var c = new Buffer("data"); -      var d = Writable("data", done); -      var _transform = function(file, enc, callback) { -	assert.equal(file.isStream(), true); -	file.contents.pipe(d); -        n++; -	callback(); -      } -      var _flush = function(callback) { -        assert.equal(n, 1); -	callback(); -      } -      var t = through.obj(_transform, _flush); -      b.pipe(t); -      b.end(new File({ -        contents: c -      })); -    }); -  }); - - -}); - -function Readable(cb){ -  var readable = new Stream.Readable(); -  readable._read = function() { -    this.push(new Buffer('data')); -    this.push(null); // no more data -  }; -  if (cb) readable.on('end', cb); -  return readable; -} - - -function Writable(check, cb) { -  var writable = new Stream.Writable(); -  var chunks = []; -  writable._write = function(chunk, _, done){ -    chunks.push(chunk); -    done(); -  }; -  if (cb) writable.on('finish', function() { -    assert.equal(check, Buffer.concat(chunks).toString()); -    cb(); -  }); -  return writable; -} | 
