device_home/node_modules/pngjs/lib/packer-async.js

   1 'use strict';
   2
   3 var util = require('util');
   4 var Stream = require('stream');
   5 var constants = require('./constants');
   6 var Packer = require('./packer');
   7
   8 var PackerAsync = module.exports = function(opt) {
   9   Stream.call(this);
  10
  11   var options = opt || {};
  12
  13   this._packer = new Packer(options);
  14   this._deflate = this._packer.createDeflate();
  15
  16   this.readable = true;
  17 };
  18 util.inherits(PackerAsync, Stream);
  19
  20
  21 PackerAsync.prototype.pack = function(data, width, height, gamma) {
  22   // Signature
  23   this.emit('data', new Buffer(constants.PNG_SIGNATURE));
  24   this.emit('data', this._packer.packIHDR(width, height));
  25
  26   if (gamma) {
  27     this.emit('data', this._packer.packGAMA(gamma));
  28   }
  29
  30   var filteredData = this._packer.filterData(data, width, height);
  31
  32   // compress it
  33   this._deflate.on('error', this.emit.bind(this, 'error'));
  34
  35   this._deflate.on('data', function(compressedData) {
  36     this.emit('data', this._packer.packIDAT(compressedData));
  37   }.bind(this));
  38
  39   this._deflate.on('end', function() {
  40     this.emit('data', this._packer.packIEND());
  41     this.emit('end');
  42   }.bind(this));
  43
  44   this._deflate.end(filteredData);
  45 };