FM / lib

/var/www/greso.tech/server/nsm/node_modules/pngjs/lib/

/var/www/greso.tech/server/nsm/node_modules/pngjs/lib

Name	Size	Mode	Actions
bitmapper.js	6477	0644	edit dl rm
bitpacker.js	4670	0644	edit dl rm
chunkstream.js	4249	0644	edit dl rm
constants.js	662	0644	edit dl rm
crc.js	853	0644	edit dl rm
filter-pack.js	4279	0644	edit dl rm
filter-parse-async.js	558	0644	edit dl rm
filter-parse-sync.js	483	0644	edit dl rm
filter-parse.js	4798	0644	edit dl rm
format-normaliser.js	2329	0644	edit dl rm
interlace.js	2004	0644	edit dl rm
packer-async.js	1162	0644	edit dl rm
packer-sync.js	1193	0644	edit dl rm
packer.js	3723	0644	edit dl rm
paeth-predictor.js	372	0644	edit dl rm
parser-async.js	4317	0644	edit dl rm
parser-sync.js	2543	0644	edit dl rm
parser.js	7720	0644	edit dl rm
png-sync.js	252	0644	edit dl rm
png.js	4418	0644	edit dl rm
sync-inflate.js	3751	0644	edit dl rm
sync-reader.js	1116	0644	edit dl rm

Edit: /var/www/greso.tech/server/nsm/node_modules/pngjs/lib/sync-reader.js (1116B)

"use strict";

let SyncReader = (module.exports = function (buffer) {
  this._buffer = buffer;
  this._reads = [];
});

SyncReader.prototype.read = function (length, callback) {
  this._reads.push({
    length: Math.abs(length), // if length < 0 then at most this length
    allowLess: length < 0,
    func: callback,
  });
};

SyncReader.prototype.process = function () {
  // as long as there is any data and read requests
  while (this._reads.length > 0 && this._buffer.length) {
    let read = this._reads[0];

if (
      this._buffer.length &&
      (this._buffer.length >= read.length || read.allowLess)
    ) {
      // ok there is any data so that we can satisfy this request
      this._reads.shift(); // == read

let buf = this._buffer;

this._buffer = buf.slice(read.length);

read.func.call(this, buf.slice(0, read.length));
    } else {
      break;
    }
  }

if (this._reads.length > 0) {
    return new Error("There are some read requests waitng on finished stream");
  }

if (this._buffer.length > 0) {
    return new Error("unrecognised content at end of stream");
  }
};

"use strict"; let SyncReader = (module.exports = function (buffer) { this._buffer = buffer; this._reads = []; }); SyncReader.prototype.read = function (length, callback) { this._reads.push({ length: Math.abs(length), // if length < 0 then at most this length allowLess: length < 0, func: callback, }); }; SyncReader.prototype.process = function () { // as long as there is any data and read requests while (this._reads.length > 0 && this._buffer.length) { let read = this._reads[0]; if ( this._buffer.length && (this._buffer.length >= read.length || read.allowLess) ) { // ok there is any data so that we can satisfy this request this._reads.shift(); // == read let buf = this._buffer; this._buffer = buf.slice(read.length); read.func.call(this, buf.slice(0, read.length)); } else { break; } } if (this._reads.length > 0) { return new Error("There are some read requests waitng on finished stream"); } if (this._buffer.length > 0) { return new Error("unrecognised content at end of stream"); } };