Update poolifier to the latest version supporting the definition of a message
handler on the workers.
Signed-off-by: Jérôme Benoit <jerome.benoit@piment-noir.org>
}
},
"poolifier": {
- "version": "2.0.2",
- "resolved": "https://registry.npmjs.org/poolifier/-/poolifier-2.0.2.tgz",
- "integrity": "sha512-qibRFXZlhYJYf/jIoayoOb31S8EeMDF89H9ujOQh1xOxLreYZ0EzCEnnOR8OdpdAxyl+JKyt7sgFLHK78WTV5w=="
+ "version": "2.1.0",
+ "resolved": "https://registry.npmjs.org/poolifier/-/poolifier-2.1.0.tgz",
+ "integrity": "sha512-tUYviyPvVLnnxdL0ROKwTohZfbf4HGldRwO2Qw4X0wrO/X3eZIbs5OELW7tMqPN3BdmbYI7JdIWfw4woQRf+rQ=="
},
"postcss": {
"version": "8.2.15",
"chalk": "^4.1.2",
"mongodb": "^4.1.1",
"mysql2": "^2.3.0",
- "poolifier": "^2.0.2",
+ "poolifier": "^2.1.0",
"reflect-metadata": "^0.1.13",
"source-map-support": "^0.5.19",
"sqlite3": "^5.0.2",
options = options ?? {} as WorkerOptions;
options.startDelay = options.startDelay ?? Constants.WORKER_START_DELAY;
options.poolOptions = options?.poolOptions ?? {} as PoolOptions<Worker>;
- // options?.messageHandler && options.poolOptions.messageHandler = options.messageHandler;
+ options?.messageHandler && (options.poolOptions.messageHandler = options.messageHandler);
let workerImplementation: WorkerAbstract = null;
switch (workerProcessType) {
case WorkerProcessType.WORKER_SET: