We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 5113111 commit a922ec7Copy full SHA for a922ec7
2 files changed
src/Worker/ContextWorkerPool.php
@@ -213,7 +213,8 @@ private static function killWorkers(
213
214
public function getWorker(): Worker
215
{
216
- return new Internal\PooledWorker($this->pull(), $this->push);
+ $worker = $this->pull();
217
+ return new Internal\PooledWorker($worker, $this->push);
218
}
219
220
/**
src/Worker/DelegatingWorkerPool.php
@@ -118,7 +118,8 @@ private function clearWaiting(\Throwable $exception): void
118
119
120
121
- return new PooledWorker($this->selectWorker(), $this->push(...));
+ $worker = $this->selectWorker();
122
+ return new PooledWorker($worker, $this->push(...));
123
124
125
public function getWorkerLimit(): int
0 commit comments