X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=src%2Fpools%2Fworker.ts;h=14c8dbe1e1d444f5404e8562c1c59ecf1585d869;hb=6fbda8efcfb5ddcc7a8baa0354ffa0d1328bc91f;hp=6b387a96088d430d455ed0a4dbb3759c1cbbe86e;hpb=72695f86742c18357f42f000ce6488d545187133;p=poolifier.git diff --git a/src/pools/worker.ts b/src/pools/worker.ts index 6b387a96..14c8dbe1 100644 --- a/src/pools/worker.ts +++ b/src/pools/worker.ts @@ -230,6 +230,12 @@ export interface IWorkerNode { * @param workerId - The worker id. */ onBackPressure?: (workerId: number) => void + /** + * Callback invoked when worker node tasks queue is empty. + * + * @param workerId - The worker id. + */ + onEmptyQueue?: (workerId: number) => void /** * Tasks queue size. *