Lines Matching refs:chunk
85 doc.on('data', function(chunk) {
86 chunks.push(chunk);
6283 function chunk(array, size, guard) {
12744 lodash.chunk = chunk;
17328 function ondata(chunk) {
17330 if (false === dest.write(chunk) && source.pause) {
17912 Readable.prototype.push = function(chunk, encoding) {
17915 if (util.isString(chunk) && !state.objectMode) {
17918 chunk = new Buffer(chunk, encoding);
17923 return readableAddChunk(this, state, chunk, encoding, false);
17927 Readable.prototype.unshift = function(chunk) {
17929 return readableAddChunk(this, state, chunk, '', true);
17932 function readableAddChunk(stream, state, chunk, encoding, addToFront) {
17933 var er = chunkInvalid(state, chunk);
17936 } else if (util.isNullOrUndefined(chunk)) {
17940 } else if (state.objectMode || chunk && chunk.length > 0) {
17949 chunk = state.decoder.write(chunk);
17956 stream.emit('data', chunk);
17960 state.length += state.objectMode ? 1 : chunk.length;
17962 state.buffer.unshift(chunk);
17964 state.buffer.push(chunk);
18171 function chunkInvalid(state, chunk) {
18173 if (!util.isBuffer(chunk) &&
18174 !util.isString(chunk) &&
18175 !util.isNullOrUndefined(chunk) &&
18185 var chunk = state.decoder.end();
18186 if (chunk && chunk.length) {
18187 state.buffer.push(chunk);
18188 state.length += state.objectMode ? 1 : chunk.length;
18331 function ondata(chunk) {
18333 var ret = dest.write(chunk);
18542 var chunk = stream.read();
18543 } while (null !== chunk && state.flowing);
18558 var chunk = state.decoder.end();
18559 if (chunk && chunk.length)
18560 self.push(chunk);
18566 stream.on('data', function(chunk) {
18569 chunk = state.decoder.write(chunk);
18570 if (!chunk || !state.objectMode && !chunk.length)
18573 var ret = self.push(chunk);
19112 function WriteReq(chunk, encoding, cb) {
19113 this.chunk = chunk;
19242 function validChunk(stream, state, chunk, cb) {
19244 if (!util.isBuffer(chunk) &&
19245 !util.isString(chunk) &&
19246 !util.isNullOrUndefined(chunk) &&
19258 Writable.prototype.write = function(chunk, encoding, cb) {
19267 if (util.isBuffer(chunk))
19277 else if (validChunk(this, state, chunk, cb)) {
19279 ret = writeOrBuffer(this, state, chunk, encoding, cb);
19306 function decodeChunk(state, chunk, encoding) {
19309 util.isString(chunk)) {
19310 chunk = new Buffer(chunk, encoding);
19312 return chunk;
19318 function writeOrBuffer(stream, state, chunk, encoding, cb) {
19319 chunk = decodeChunk(state, chunk, encoding);
19320 if (util.isBuffer(chunk))
19322 var len = state.objectMode ? 1 : chunk.length;
19332 state.buffer.push(new WriteReq(chunk, encoding, cb));
19334 doWrite(stream, state, false, len, chunk, encoding, cb);
19339 function doWrite(stream, state, writev, len, chunk, encoding, cb) {
19345 stream._writev(chunk, state.onwrite);
19347 stream._write(chunk, encoding, state.onwrite);
19448 var chunk = entry.chunk;
19451 var len = state.objectMode ? 1 : chunk.length;
19453 doWrite(stream, state, false, len, chunk, encoding, cb);
19474 Writable.prototype._write = function(chunk, encoding, cb) {
19481 Writable.prototype.end = function(chunk, encoding, cb) {
19484 if (util.isFunction(chunk)) {
19485 cb = chunk;
19486 chunk = null;
19493 if (!util.isNullOrUndefined(chunk))
19494 this.write(chunk, encoding);
19922 Transform.prototype.push = function(chunk, encoding) {
19924 return Duplex.prototype.push.call(this, chunk, encoding);
19937 Transform.prototype._transform = function(chunk, encoding, cb) {
19941 Transform.prototype._write = function(chunk, encoding, cb) {
19944 ts.writechunk = chunk;
20038 PassThrough.prototype._transform = function(chunk, encoding, cb) {
20039 cb(null, chunk);
20266 return function(chunk) {
20267 _this.chunks.push(chunk);
20268 return _this.data.Length += chunk.length;
20274 PDFReference.prototype.write = function(chunk) {
20276 if (!Buffer.isBuffer(chunk)) {
20277 chunk = new Buffer(chunk + '\n', 'binary');
20279 this.uncompressedLength += chunk.length;
20287 return this.deflate.write(chunk);
20289 this.chunks.push(chunk);
20290 return this.data.Length += chunk.length;
20294 PDFReference.prototype.end = function(chunk) {
20295 if (typeof chunk === 'string' || Buffer.isBuffer(chunk)) {
20296 this.write(chunk);
20306 var chunk, _i, _len, _ref;
20314 chunk = _ref[_i];
20315 this.document._write(chunk);
20548 var chunk;
20549 while (null !== (chunk = engine.read())) {
20550 buffers.push(chunk);
20551 nread += chunk.length;
20813 Zlib.prototype._transform = function(chunk, encoding, cb) {
20817 var last = ending && (!chunk || ws.length === chunk.length);
20819 if (!chunk === null && !Buffer.isBuffer(chunk))
20832 if (chunk.length >= ws.length) {
20838 this._processChunk(chunk, flushFlag, cb);
20841 Zlib.prototype._processChunk = function(chunk, flushFlag, cb) {
20842 var availInBefore = chunk && chunk.length;
20861 chunk, // in
20880 chunk, // in
20887 req.buffer = chunk;
20928 chunk,
20935 newReq.buffer = chunk;
23080 var i, l, len, pos, chunk, result;
23092 chunk = chunks[i];
23093 result.set(chunk, pos);
23094 pos += chunk.length;
27744 PDFPage.prototype.write = function(chunk) {
27745 return this.content.write(chunk);