Lines Matching refs:chunk
5399 function bufferToString(chunk) {
5400 if (typeof chunk === 'string') {
5401 return chunk;
5405 return textDecoder.decode(chunk);
5408 return chunk.toString();
6068 …nts, _iteratorNormalCompletion, _didIteratorError, _iteratorError, _iterator, _step, _value, chunk;
6126 chunk = _value;
6127 …saxesParser.write(bufferToString(chunk)); // saxesParser.write and saxesParser.on() are synchronou…
6417 value: function write(chunk, offset, length) {
6421 chunk.copy(this.buffer, this.iWrite, offset, offset + size);
6505 _pipe: function _pipe(chunk) {
6516 pipe.write(chunk.toBuffer(), function () {
6533 _writeToBuffers: function _writeToBuffers(chunk) {
6535 var inLen = chunk.length;
6542 inPos += buffer.write(chunk, inPos, inLen - inPos);
6549 var chunk;
6566 chunk = new StringBufChunk(data);
6576 chunk = new BufferChunk(data);
6586 chunk = new StringChunk(data, encoding);
6604 _this2._writeToBuffers(chunk);
6620 return _this2._pipe(chunk);
6628 _this2._writeToBuffers(chunk);
6638 _this2.emit('data', chunk.toBuffer());
6641 _this2._writeToBuffers(chunk);
6675 end: function end(chunk, encoding, callback) {
6692 if (chunk) {
6693 this.write(chunk, encoding, writeComplete);
7638 value: function unshift(chunk) {
7639 return this.stream.unshift(chunk);
24390 …nks, _iteratorNormalCompletion, _didIteratorError, _iteratorError, _iterator, _step, _value, chunk;
24426 chunk = _value;
24427 chunks.push(chunk);
36971 StreamCipher.prototype._update = function (chunk) {
36984 var out = this._mode.encrypt(this, chunk);
36987 this._ghash.update(chunk);
36992 this._len += chunk.length;
37078 var chunk;
37082 while (chunk = this._cache.get(this._autopadding)) {
37083 thing = this._mode.decrypt(this, chunk);
37091 var chunk = this._cache.flush();
37094 return unpad(this._mode.decrypt(this, chunk));
37095 } else if (chunk) {
37216 var chunk;
37220 while (chunk = this._cache.get()) {
37221 thing = this._mode.encrypt(this, chunk);
37231 var chunk = this._cache.flush();
37234 chunk = this._mode.encrypt(this, chunk);
37238 return chunk;
37241 if (!chunk.equals(PADDING)) {
37384 var chunk;
37387 chunk = this.cache.slice(0, 16);
37389 this.ghash(chunk);
37520 exports.encrypt = function (self, chunk, decrypt) {
37521 var len = chunk.length;
37526 out[i] = encryptByte(self, chunk[i], decrypt);
37545 exports.encrypt = function (self, chunk, decrypt) {
37546 var len = chunk.length;
37551 out[i] = encryptByte(self, chunk[i], decrypt);
37575 exports.encrypt = function (self, chunk) {
37576 var chunkNum = Math.ceil(chunk.length / blockSize);
37593 var pad = self._cache.slice(0, chunk.length);
37595 self._cache = self._cache.slice(chunk.length);
37596 return xor(chunk, pad);
37836 exports.encrypt = function (self, chunk) {
37837 while (self._cache.length < chunk.length) {
37841 var pad = self._cache.slice(0, chunk.length);
37843 self._cache = self._cache.slice(chunk.length);
37844 return xor(chunk, pad);
37872 StreamCipher.prototype._update = function (chunk) {
37873 return this._mode.encrypt(this, chunk, this._decrypt);
49251 HashBase.prototype._transform = function (chunk, encoding, callback) {
49255 this.update(chunk, encoding);
51079 FlateWorker.prototype.processChunk = function (chunk) {
51080 this.meta = chunk.meta;
51086 this._pako.push(utils.transformTo(ARRAY_TYPE, chunk.data), false);
51471 ZipFileWorker.prototype.push = function (chunk) {
51472 var currentFilePercent = chunk.meta.percent || 0;
51477 this.contentBuffer.push(chunk);
51479 this.bytesWritten += chunk.data.length;
51481 data: chunk.data,
51600 previous.on('data', function (chunk) {
51601 self.processChunk(chunk);
51915 stream.on("data", function (chunk) {
51917 data: chunk,
52876 ConvertWorker.prototype.processChunk = function (chunk) {
52878 data: utils.transformTo(this.destType, chunk.data),
52879 meta: chunk.meta
52909 Crc32Probe.prototype.processChunk = function (chunk) {
52910 this.streamInfo.crc32 = crc32(chunk.data, this.streamInfo.crc32 || 0);
52911 this.push(chunk);
52940 DataLengthProbe.prototype.processChunk = function (chunk) {
52941 if (chunk) {
52943 this.streamInfo[this.propName] = length + chunk.data.length;
52946 GenericWorker.prototype.processChunk.call(this, chunk);
53127 push: function push(chunk) {
53128 this.emit("data", chunk);
53242 previous.on('data', function (chunk) {
53243 self.processChunk(chunk);
53306 processChunk: function processChunk(chunk) {
53307 this.push(chunk);
53557 this._worker.on(evt, function (chunk) {
53558 fn.call(self, chunk.data, chunk.meta);
53895 Utf8DecodeWorker.prototype.processChunk = function (chunk) {
53896 …var data = utils.transformTo(support.uint8array ? "uint8array" : "array", chunk.data); // 1st step…
53926 meta: chunk.meta
53959 Utf8EncodeWorker.prototype.processChunk = function (chunk) {
53961 data: exports.utf8encode(chunk.data),
53962 meta: chunk.meta
54078 stringifyByChunk: function stringifyByChunk(array, type, chunk) {
54083 if (len <= chunk) {
54089 result.push(String.fromCharCode.apply(null, array.slice(k, Math.min(k + chunk, len))));
54091 result.push(String.fromCharCode.apply(null, array.subarray(k, Math.min(k + chunk, len))));
54094 k += chunk;
54157 var chunk = 65536,
54168 while (chunk > 1) {
54170 return arrayToStringHelper.stringifyByChunk(array, type, chunk);
54172 chunk = Math.floor(chunk / 2);
62053 Deflate.prototype.onData = function (chunk) {
62054 this.chunks.push(chunk);
62481 Inflate.prototype.onData = function (chunk) {
62482 this.chunks.push(chunk);
62658 var i, l, len, pos, chunk, result; // calculate data length
62671 chunk = chunks[i];
62672 result.set(chunk, pos);
62673 pos += chunk.length;
71617 PassThrough.prototype._transform = function (chunk, encoding, cb) {
71618 cb(null, chunk);
71672 function _uint8ArrayToBuffer(chunk) {
71673 return Buffer.from(chunk);
71844 Readable.prototype.push = function (chunk, encoding) {
71849 if (typeof chunk === 'string') {
71853 chunk = Buffer.from(chunk, encoding);
71863 return readableAddChunk(this, chunk, encoding, false, skipChunkCheck);
71867 Readable.prototype.unshift = function (chunk) {
71868 return readableAddChunk(this, chunk, null, true, false);
71871 function readableAddChunk(stream, chunk, encoding, addToFront, skipChunkCheck) {
71872 debug('readableAddChunk', chunk);
71875 if (chunk === null) {
71880 if (!skipChunkCheck) er = chunkInvalid(state, chunk);
71884 } else if (state.objectMode || chunk && chunk.length > 0) {
71885 …if (typeof chunk !== 'string' && !state.objectMode && Object.getPrototypeOf(chunk) !== Buffer.prot…
71886 chunk = _uint8ArrayToBuffer(chunk);
71890 …estroy(stream, new ERR_STREAM_UNSHIFT_AFTER_END_EVENT());else addChunk(stream, state, chunk, true);
71899 chunk = state.decoder.write(chunk);
71900 …if (state.objectMode || chunk.length !== 0) addChunk(stream, state, chunk, false);else maybeReadMo…
71902 addChunk(stream, state, chunk, false);
71917 function addChunk(stream, state, chunk, addToFront) {
71920 stream.emit('data', chunk);
71923 state.length += state.objectMode ? 1 : chunk.length;
71924 if (addToFront) state.buffer.unshift(chunk);else state.buffer.push(chunk);
71931 function chunkInvalid(state, chunk) {
71934 …if (!_isUint8Array(chunk) && typeof chunk !== 'string' && chunk !== undefined && !state.objectMode…
71935 er = new ERR_INVALID_ARG_TYPE('chunk', ['string', 'Buffer', 'Uint8Array'], chunk);
72114 var chunk = state.decoder.end();
72116 if (chunk && chunk.length) {
72117 state.buffer.push(chunk);
72118 state.length += state.objectMode ? 1 : chunk.length;
72301 function ondata(chunk) {
72303 var ret = dest.write(chunk);
72578 var chunk = state.decoder.end();
72579 if (chunk && chunk.length) _this.push(chunk);
72584 stream.on('data', function (chunk) {
72586 …if (state.decoder) chunk = state.decoder.write(chunk); // don't skip over falsy values in objectMo…
72588 …if (state.objectMode && (chunk === null || chunk === undefined)) return;else if (!state.objectMode…
72590 var ret = _this.push(chunk);
72887 Transform.prototype.push = function (chunk, encoding) {
72889 return Duplex.prototype.push.call(this, chunk, encoding);
72902 Transform.prototype._transform = function (chunk, encoding, cb) {
72906 Transform.prototype._write = function (chunk, encoding, cb) {
72909 ts.writechunk = chunk;
72983 function WriteReq(chunk, encoding, cb) {
72984 this.chunk = chunk;
73028 function _uint8ArrayToBuffer(chunk) {
73029 return Buffer.from(chunk);
73224 function validChunk(stream, state, chunk, cb) {
73227 if (chunk === null) {
73229 } else if (typeof chunk !== 'string' && !state.objectMode) {
73230 er = new ERR_INVALID_ARG_TYPE('chunk', ['string', 'Buffer'], chunk);
73242 Writable.prototype.write = function (chunk, encoding, cb) {
73246 var isBuf = !state.objectMode && _isUint8Array(chunk);
73248 if (isBuf && !Buffer.isBuffer(chunk)) {
73249 chunk = _uint8ArrayToBuffer(chunk);
73259 if (state.ending) writeAfterEnd(this, cb);else if (isBuf || validChunk(this, state, chunk, cb)) {
73261 ret = writeOrBuffer(this, state, isBuf, chunk, encoding, cb);
73297 function decodeChunk(state, chunk, encoding) {
73298 if (!state.objectMode && state.decodeStrings !== false && typeof chunk === 'string') {
73299 chunk = Buffer.from(chunk, encoding);
73302 return chunk;
73317 function writeOrBuffer(stream, state, isBuf, chunk, encoding, cb) {
73319 var newChunk = decodeChunk(state, chunk, encoding);
73321 if (chunk !== newChunk) {
73324 chunk = newChunk;
73328 var len = state.objectMode ? 1 : chunk.length;
73337 chunk: chunk,
73352 doWrite(stream, state, false, len, chunk, encoding, cb);
73358 function doWrite(stream, state, writev, len, chunk, encoding, cb) {
73363 …_DESTROYED('write'));else if (writev) stream._writev(chunk, state.onwrite);else stream._write(chun…
73476 var chunk = entry.chunk;
73479 var len = state.objectMode ? 1 : chunk.length;
73480 doWrite(stream, state, false, len, chunk, encoding, cb);
73499 Writable.prototype._write = function (chunk, encoding, cb) {
73505 Writable.prototype.end = function (chunk, encoding, cb) {
73508 if (typeof chunk === 'function') {
73509 cb = chunk;
73510 chunk = null;
73517 if (chunk !== null && chunk !== undefined) this.write(chunk, encoding); // .end() fully uncorks
75899 this.chunk = "";
76044 value: function write(chunk) {
76051 if (chunk === null) {
76055 chunk = "";
76056 } else if (_typeof(chunk) === "object") {
76057 chunk = chunk.toString();
76067 chunk = "".concat(this.carriedFromPrevious).concat(chunk);
76071 var limit = chunk.length;
76072 var lastCode = chunk.charCodeAt(limit - 1);
76080 this.carriedFromPrevious = chunk[limit - 1];
76082 chunk = chunk.slice(0, limit);
76086 this.chunk = chunk;
76121 var chunk = this.chunk,
76128 if (i >= chunk.length) {
76134 var code = chunk.charCodeAt(i);
76151 if (chunk.charCodeAt(i + 1) === NL) {
76184 var final = 0x10000 + (code - 0xD800) * 0x400 + (chunk.charCodeAt(i + 1) - 0xDC00);
76206 var chunk = this.chunk,
76213 if (i >= chunk.length) {
76219 var code = chunk.charCodeAt(i);
76240 var next = chunk.charCodeAt(i + 1);
76278 var final = 0x10000 + (code - 0xD800) * 0x400 + (chunk.charCodeAt(i + 1) - 0xDC00);
76321 var chunk = this.chunk; // eslint-disable-next-line no-constant-condition
76329 this.text += chunk.slice(start, this.prevI);
76334 this.text += "".concat(chunk.slice(start, this.prevI), "\n");
76353 var chunk = this.chunk; // eslint-disable-next-line no-constant-condition
76360 this.text += "".concat(chunk.slice(start, this.prevI), "\n");
76366 this.text += chunk.slice(start);
76373 this.text += chunk.slice(start, this.prevI);
76390 var chunk = this.chunk,
76397 this.name += chunk.slice(start);
76403 this.name += chunk.slice(start, this.prevI);
76455 if (this.chunk.charCodeAt(0) === 0xFEFF) {
76680 var chunk = this.chunk; // eslint-disable-next-line no-labels, no-restricted-syntax
76686 this.entity += "".concat(chunk.slice(start, this.prevI), "\n");
76693 var entity = this.entity + chunk.slice(start, this.prevI);
76714 this.entity += chunk.slice(start); // eslint-disable-next-line no-labels
76913 var chunk = this.chunk,
76920 this.piTarget += chunk.slice(start);
76927 this.piTarget += chunk.slice(start, this.prevI);
77359 chunk = this.chunk;
77365 this.pushAttrib(this.name, this.text + chunk.slice(start, this.prevI));
77372 this.text += chunk.slice(start, this.prevI);
77380 this.text += "".concat(chunk.slice(start, this.prevI), " ");
77385 this.text += chunk.slice(start, this.prevI);
77390 this.text += chunk.slice(start);
77497 var chunk = this.chunk,
77509 var slice = chunk.slice(start, this.prevI);
77529 this.text += chunk.slice(start, this.prevI);
77565 this.text += "".concat(chunk.slice(start, this.prevI), "\n");
77574 this.text += chunk.slice(start);
77595 var chunk = this.chunk,
77610 var slice = chunk.slice(start, this.prevI);
77629 this.text += chunk.slice(start, this.prevI);
77638 this.text += "".concat(chunk.slice(start, this.prevI), "\n");
77646 this.text += chunk.slice(start);
78919 function ondata(chunk) {
78921 if (false === dest.write(chunk) && source.pause) {
79167 PassThrough.prototype._transform = function (chunk, encoding, cb) {
79168 cb(null, chunk);
79235 function _uint8ArrayToBuffer(chunk) {
79236 return Buffer.from(chunk);
79394 Readable.prototype.push = function (chunk, encoding) {
79399 if (typeof chunk === 'string') {
79403 chunk = Buffer.from(chunk, encoding);
79413 return readableAddChunk(this, chunk, encoding, false, skipChunkCheck);
79417 Readable.prototype.unshift = function (chunk) {
79418 return readableAddChunk(this, chunk, null, true, false);
79421 function readableAddChunk(stream, chunk, encoding, addToFront, skipChunkCheck) {
79424 if (chunk === null) {
79429 if (!skipChunkCheck) er = chunkInvalid(state, chunk);
79433 } else if (state.objectMode || chunk && chunk.length > 0) {
79434 …if (typeof chunk !== 'string' && !state.objectMode && Object.getPrototypeOf(chunk) !== Buffer.prot…
79435 chunk = _uint8ArrayToBuffer(chunk);
79439 …('error', new Error('stream.unshift() after end event'));else addChunk(stream, state, chunk, true);
79446 chunk = state.decoder.write(chunk);
79447 …if (state.objectMode || chunk.length !== 0) addChunk(stream, state, chunk, false);else maybeReadMo…
79449 addChunk(stream, state, chunk, false);
79460 function addChunk(stream, state, chunk, addToFront) {
79462 stream.emit('data', chunk);
79466 state.length += state.objectMode ? 1 : chunk.length;
79467 if (addToFront) state.buffer.unshift(chunk);else state.buffer.push(chunk);
79474 function chunkInvalid(state, chunk) {
79477 …if (!_isUint8Array(chunk) && typeof chunk !== 'string' && chunk !== undefined && !state.objectMode…
79650 var chunk = state.decoder.end();
79652 if (chunk && chunk.length) {
79653 state.buffer.push(chunk);
79654 state.length += state.objectMode ? 1 : chunk.length;
79793 function ondata(chunk) {
79796 var ret = dest.write(chunk);
80013 var chunk = state.decoder.end();
80014 if (chunk && chunk.length) _this.push(chunk);
80019 stream.on('data', function (chunk) {
80021 …if (state.decoder) chunk = state.decoder.write(chunk); // don't skip over falsy values in objectMo…
80023 …if (state.objectMode && (chunk === null || chunk === undefined)) return;else if (!state.objectMode…
80025 var ret = _this.push(chunk);
80352 Transform.prototype.push = function (chunk, encoding) {
80354 return Duplex.prototype.push.call(this, chunk, encoding);
80367 Transform.prototype._transform = function (chunk, encoding, cb) {
80371 Transform.prototype._write = function (chunk, encoding, cb) {
80374 ts.writechunk = chunk;
80456 function WriteReq(chunk, encoding, cb) {
80457 this.chunk = chunk;
80514 function _uint8ArrayToBuffer(chunk) {
80515 return Buffer.from(chunk);
80698 function validChunk(stream, state, chunk, cb) {
80702 if (chunk === null) {
80704 } else if (typeof chunk !== 'string' && chunk !== undefined && !state.objectMode) {
80717 Writable.prototype.write = function (chunk, encoding, cb) {
80721 var isBuf = !state.objectMode && _isUint8Array(chunk);
80723 if (isBuf && !Buffer.isBuffer(chunk)) {
80724 chunk = _uint8ArrayToBuffer(chunk);
80734 if (state.ended) writeAfterEnd(this, cb);else if (isBuf || validChunk(this, state, chunk, cb)) {
80736 ret = writeOrBuffer(this, state, isBuf, chunk, encoding, cb);
80763 function decodeChunk(state, chunk, encoding) {
80764 if (!state.objectMode && state.decodeStrings !== false && typeof chunk === 'string') {
80765 chunk = Buffer.from(chunk, encoding);
80768 return chunk;
80783 function writeOrBuffer(stream, state, isBuf, chunk, encoding, cb) {
80785 var newChunk = decodeChunk(state, chunk, encoding);
80787 if (chunk !== newChunk) {
80790 chunk = newChunk;
80794 var len = state.objectMode ? 1 : chunk.length;
80803 chunk: chunk,
80818 doWrite(stream, state, false, len, chunk, encoding, cb);
80824 function doWrite(stream, state, writev, len, chunk, encoding, cb) {
80829 …if (writev) stream._writev(chunk, state.onwrite);else stream._write(chunk, encoding, state.onwrite…
80943 var chunk = entry.chunk;
80946 var len = state.objectMode ? 1 : chunk.length;
80947 doWrite(stream, state, false, len, chunk, encoding, cb);
80966 Writable.prototype._write = function (chunk, encoding, cb) {
80972 Writable.prototype.end = function (chunk, encoding, cb) {
80975 if (typeof chunk === 'function') {
80976 cb = chunk;
80977 chunk = null;
80984 if (chunk !== null && chunk !== undefined) this.write(chunk, encoding); // .end() fully uncorks