+ public unshiftTask (task: Task<Data>): number {
+ const tasksQueueSize = this.tasksQueue.unshift(task)
+ if (this.hasBackPressure() && !this.onBackPressureStarted) {
+ this.onBackPressureStarted = true
+ this.emit('backPressure', { workerId: this.info.id as number })
+ this.onBackPressureStarted = false
+ }
+ return tasksQueueSize