* Describes how this stop operation behaves. * @returns {void}
()
| 250 | * @returns {void} |
| 251 | */ |
| 252 | stop() { |
| 253 | this._stopped = true; |
| 254 | const queue = this._queued; |
| 255 | this._queued = new ArrayQueue(); |
| 256 | const root = this._root; |
| 257 | for (const entry of queue) { |
| 258 | this._entries.delete( |
| 259 | this._getKey(/** @type {AsyncQueueEntry<T, K, R>} */ (entry).item) |
| 260 | ); |
| 261 | root._activeTasks++; |
| 262 | this._handleResult( |
| 263 | /** @type {AsyncQueueEntry<T, K, R>} */ (entry), |
| 264 | new WebpackError("Queue was stopped") |
| 265 | ); |
| 266 | } |
| 267 | } |
| 268 | |
| 269 | /** |
| 270 | * Increase parallelism. |
no test coverage detected