MCPcopy Create free account
hub / github.com/Keyang/node-csvtojson / ProcessorFork

Function ProcessorFork

v2/ProcessFork.js:27–39  ·  view source on GitHub ↗
(converter)

Source from the content-addressed store, hash-verified

25var ProcessorFork = /** @class */ (function (_super) {
26 __extends(ProcessorFork, _super);
27 function ProcessorFork(converter) {
28 var _this = _super.call(this, converter) || this;
29 _this.converter = converter;
30 _this.inited = false;
31 _this.resultBuf = [];
32 _this.leftChunk = "";
33 _this.finalChunk = false;
34 _this.childProcess = require("child_process").spawn(process.execPath, [__dirname + "/../v2/worker.js"], {
35 stdio: ["pipe", "pipe", "pipe", "ipc"]
36 });
37 _this.initWorker();
38 return _this;
39 }
40 ProcessorFork.prototype.flush = function () {
41 var _this = this;
42 return new Promise(function (resolve, reject) {

Callers

nothing calls this directly

Calls 1

initWorkerMethod · 0.80

Tested by

no test coverage detected