We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent b3dfb64 commit f298764Copy full SHA for f298764
src/index.js
@@ -41,23 +41,19 @@ Blobs.prototype.createWriteStream = function (opts, cb) {
41
Transform.call(this, options)
42
this._bufs = []
43
this._evilIsFlushing = false
44
- this._evilPending = 0
45
- this._evilWantFinish = false
46
this._evilFlushed = false
47
}
48
49
util.inherits(FlushableStream, Transform)
50
51
FlushableStream.prototype._transform = function (chunk, encoding, done) {
52
- this._evilPending++
53
// coerce number arguments to strings, since Buffer(number) does
54
// uninitialized memory allocation
55
if (typeof buf === 'number') chunk = chunk.toString()
56
57
this._bufs.push(Buffer.isBuffer(chunk) ? chunk : new Buffer(chunk))
58
this.push(chunk)
59
60
- this._evilPending--
61
if (done) done()
62
63
0 commit comments