Searched defs:finalize (Results 1 - 1 of 1) sorted by relevance
/interface/sdk-js/build-tools/dts_parser/build_package/ |
H A D | JS_API_COUNT.js | 17 var n=r(79896),i=r(76965),a=r(22268),o=r(16928),s=r(91789),c=r(39023).inherits,l=r(82383),u=r(34198).Transform,d="win32"===process.platform,p=function(e,t){if(!(this instanceof p))return new p(e,t);"string"!=typeof e&&(t=e,e="zip"),t=this.options=s.defaults(t,{highWaterMark:1048576,statConcurrency:4}),u.call(this,t),this._format=!1,this._module=!1,this._pending=0,this._pointer=0,this._entriesCount=0,this._entriesProcessedCount=0,this._fsEntriesTotalBytes=0,this._fsEntriesProcessedBytes=0,this._queue=a.queue(this._onQueueTask.bind(this),1),this._queue.drain(this._onQueueDrain.bind(this)),this._statQueue=a.queue(this._onStatQueueTask.bind(this),t.statConcurrency),this._statQueue.drain(this._onQueueDrain.bind(this)),this._state={aborted:!1,finalize:!1,finalizing:!1,finalized:!1,modulePiped:!1},this._streams=[]};c(p,u),p.prototype._abort=function(){this._state.aborted=!0,this._queue.kill(),this._statQueue.kill(),this._queue.idle()&&this._shutdown()},p.prototype._append=function(e,t){var r={source:null,filepath:e};(t=t||{}).name||(t.name=e),t.sourcePath=e,r.data=t,this._entriesCount++,t.stats&&t.stats instanceof n.Stats?(r=this._updateQueueTaskWithStats(r,t.stats))&&(t.stats.size&&(this._fsEntriesTotalBytes+=t.stats.size),this._queue.push(r)):this._statQueue.push(r)},p.prototype._finalize=function(){this._state.finalizing||this._state.finalized||this._state.aborted||(this._state.finalizing=!0,this._moduleFinalize(),this._state.finalizing=!1,this._state.finalized=!0)},p.prototype._maybeFinalize=function(){return!(this._state.finalizing||this._state.finalized||this._state.aborted)&&(!!(this._state.finalize&&0===this._pending&&this._queue.idle()&&this._statQueue.idle())&&(this._finalize(),!0))},p.prototype._moduleAppend=function(e,t,r){this._state.aborted?r():this._module.append(e,t,function(e){if(this._task=null,this._state.aborted)this._shutdown();else{if(e)return this.emit("error",e),void setImmediate(r);this.emit("entry",t),this._entriesProcessedCount++,t.stats&&t.stats.size&&(this._fsEntriesProcessedBytes+=t.stats.size),this.emit("progress",{entries:{total:this._entriesCount,processed:this._entriesProcessedCount},fs:{totalBytes:this._fsEntriesTotalBytes,processedBytes:this._fsEntriesProcessedBytes}}),setImmediate(r)}}.bind(this))},p.prototype._moduleFinalize=function(){"function"==typeof this._module.finalize?this._module.finalize():"function"==typeof this._module.end?this._module.end():this.emit("error",new l("NOENDMETHOD"))},p.prototype._modulePipe=function(){this._module.on("error",this._onModuleError.bind(this)),this._module.pipe(this),this._state.modulePiped=!0},p.prototype._moduleSupports=function(e){return!(!this._module.supports||!this._module.supports[e])&&this._module.supports[e]},p.prototype._moduleUnpipe=function(){this._module.unpipe(this),this._state.modulePiped=!1},p.prototype._normalizeEntryData=function(e,t){e=s.defaults(e,{type:"file",name:null,date:null,mode:null,prefix:null,sourcePath:null,stats:!1}),t&&!1===e.stats&&(e.stats=t);var r="directory"===e.type;return e.name&&("string"==typeof e.prefix&&""!==e.prefix&&(e.name=e.prefix+"/"+e.name,e.prefix=null),e.name=s.sanitizePath(e.name),"symlink"!==e.type&&"/"===e.name.slice(-1)?(r=!0,e.type="directory"):r&&(e.name+="/")),"number"==typeof e.mode?e.mode&=d?511:4095:e.stats&&null===e.mode?(e.mode=d?511&e.stats.mode:4095&e.stats.mode,d&&r&&(e.mode=493)):null===e.mode&&(e.mode=r?493:420),e.stats&&null===e.date?e.date=e.stats.mtime:e.date=s.dateify(e.date),e},p.prototype._onModuleError=function(e){this.emit("error",e)},p.prototype._onQueueDrain=function(){this._state.finalizing||this._state.finalized||this._state.aborted||this._state.finalize&&0===this._pending&&this._queue.idle()&&this._statQueue.idle()&&this._finalize()},p.prototype._onQueueTask=function(e,t){var r=()=>{e.data.callback&&e.data.callback(),t()};this._state.finalizing||this._state.finalized||this._state.aborted?r():(this._task=e,this._moduleAppend(e.source,e.data,r))},p.prototype._onStatQueueTask=function(e,t){this._state.finalizing||this._state.finalized||this._state.aborted?t():n.lstat(e.filepath,function(r,n){if(this._state.aborted)setImmediate(t);else{if(r)return this._entriesCount--,this.emit("warning",r),void setImmediate(t);(e=this._updateQueueTaskWithStats(e,n))&&(n.size&&(this._fsEntriesTotalBytes+=n.size),this._queue.push(e)),setImmediate(t)}}.bind(this))},p.prototype._shutdown=function(){this._moduleUnpipe(),this.end()},p.prototype._transform=function(e,t,r){e&&(this._pointer+=e.length),r(null,e)},p.prototype._updateQueueTaskWithStats=function(e,t){if(t.isFile())e.data.type="file",e.data.sourceType="stream",e.source=s.lazyReadStream(e.filepath);else if(t.isDirectory()&&this._moduleSupports("directory"))e.data.name=s.trailingSlashIt(e.data.name),e.data.type="directory",e.data.sourcePath=s.trailingSlashIt(e.filepath),e.data.sourceType="buffer",e.source=Buffer.concat([]);else{if(!t.isSymbolicLink()||!this._moduleSupports("symlink"))return t.isDirectory()?this.emit("warning",new l("DIRECTORYNOTSUPPORTED",e.data)):t.isSymbolicLink()?this.emit("warning",new l("SYMLINKNOTSUPPORTED",e.data)):this.emit("warning",new l("ENTRYNOTSUPPORTED",e.data)),null;var r=n.readlinkSync(e.filepath),i=o.dirname(e.filepath);e.data.type="symlink",e.data.linkname=o.relative(i,o.resolve(i,r)),e.data.sourceType="buffer",e.source=Buffer.concat([])}return e.data=this._normalizeEntryData(e.data,t),e},p.prototype.abort=function(){return this._state.aborted||this._state.finalized||this._abort(),this},p.prototype.append=function(e,t){if(this._state.finalize||this._state.aborted)return this.emit("error",new l("QUEUECLOSED")),this;if("string"!=typeof(t=this._normalizeEntryData(t)).name||0===t.name.length)return this.emit("error",new l("ENTRYNAMEREQUIRED")),this;if("directory"===t.type&&!this._moduleSupports("directory"))return this.emit("error",new l("DIRECTORYNOTSUPPORTED",{name:t.name})),this;if(e=s.normalizeInputSource(e),Buffer.isBuffer(e))t.sourceType="buffer";else{if(!s.isStream(e))return this.emit("error",new l("INPUTSTEAMBUFFERREQUIRED",{name:t.name})),this;t.sourceType="stream"}return this._entriesCount++,this._queue.push({data:t,source:e}),this},p.prototype.directory=function(e,t,r){if(this._state.finalize||this._state.aborted)return this.emit("error",new l("QUEUECLOSED")),this;if("string"!=typeof e||0===e.length)return this.emit("error",new l("DIRECTORYDIRPATHREQUIRED")),this;this._pending++,!1===t?t="":"string"!=typeof t&&(t=e);var n=!1;"function"==typeof r?(n=r,r={}):"object"!=typeof r&&(r={});var a=i(e,{stat:!0,dot:!0});return a.on("error",function(e){this.emit("error",e)}.bind(this)),a.on("match",function(i){a.pause();var o=!1,s=Object.assign({},r);s.name=i.relative,s.prefix=t,s.stats=i.stat,s.callback=a.resume.bind(a);try{if(n)if(!1===(s=n(s)))o=!0;else if("object"!=typeof s)throw new l("DIRECTORYFUNCTIONINVALIDDATA",{dirpath:e})}catch(e){return void this.emit("error",e)}o?a.resume():this._append(i.absolute,s)}.bind(this)),a.on("end",function(){this._pending--,this._maybeFinalize()}.bind(this)),this},p.prototype.file=function(e,t){return this._state.finalize||this._state.aborted?(this.emit("error",new l("QUEUECLOSED")),this):"string"!=typeof e||0===e.length?(this.emit("error",new l("FILEFILEPATHREQUIRED")),this):(this._append(e,t),this)},p.prototype.glob=function(e,t,r){this._pending++,t=s.defaults(t,{stat:!0,pattern:e});var n=i(t.cwd||".",t);return n.on("error",function(e){this.emit("error",e)}.bind(this)),n.on("match",function(e){n.pause();var t=Object.assign({},r);t.callback=n.resume.bind(n),t.stats=e.stat,t.name=e.relative,this._append(e.absolute,t)}.bind(this)),n.on("end",function(){this._pending--,this._maybeFinalize()}.bind(this)),this},p.prototype.finalize method [all...] |
Completed in 16 milliseconds