* @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.
*