summary |
shortlog |
log |
commit | commitdiff |
tree
raw |
patch |
inline | side by side (from parent 1:
7654578)
Signed-off-by: Jérôme Benoit <jerome.benoit@sap.com>
/** @inheritDoc */
public async destroy (): Promise<void> {
await Promise.all(
/** @inheritDoc */
public async destroy (): Promise<void> {
await Promise.all(
- this.workerNodes.map(async workerNode => {
- this.flushTasksQueueByWorker(workerNode.worker)
+ this.workerNodes.map(async (workerNode, workerNodeKey) => {
+ this.flushTasksQueue(workerNodeKey)
await this.destroyWorker(workerNode.worker)
})
)
await this.destroyWorker(workerNode.worker)
})
)