1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
|
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;
}
|
