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
|
'use strict';
var util = require('util');
var Transform = require('stream').Transform;
function ctor(options, transform) {
util.inherits(FirstChunk, Transform);
if (typeof options === 'function') {
transform = options;
options = {};
}
if (typeof transform !== 'function') {
throw new Error('transform function required');
}
function FirstChunk(options2) {
if (!(this instanceof FirstChunk)) {
return new FirstChunk(options2);
}
Transform.call(this, options2);
this._firstChunk = true;
this._transformCalled = false;
this._minSize = options.minSize;
}
FirstChunk.prototype._transform = function (chunk, enc, cb) {
this._enc = enc;
if (this._firstChunk) {
this._firstChunk = false;
if (this._minSize == null) {
transform.call(this, chunk, enc, cb);
this._transformCalled = true;
return;
}
this._buffer = chunk;
cb();
return;
}
if (this._minSize == null) {
this.push(chunk);
cb();
return;
}
if (this._buffer.length < this._minSize) {
this._buffer = Buffer.concat([this._buffer, chunk]);
cb();
return;
}
if (this._buffer.length >= this._minSize) {
transform.call(this, this._buffer.slice(), enc, function () {
this.push(chunk);
cb();
}.bind(this));
this._transformCalled = true;
this._buffer = false;
return;
}
this.push(chunk);
cb();
};
FirstChunk.prototype._flush = function (cb) {
if (!this._buffer) {
cb();
return;
}
if (this._transformCalled) {
this.push(this._buffer);
cb();
} else {
transform.call(this, this._buffer.slice(), this._enc, cb);
}
};
return FirstChunk;
}
module.exports = function () {
return ctor.apply(ctor, arguments)();
};
module.exports.ctor = ctor;
|
