mirror_php/parallel
1
0
Fork 0
mirror of https://github.com/amphp/parallel.git synced 2025-02-22 05:42:36 +01:00
Code Issues Actions Packages Projects Releases Wiki Activity

when() → onResolve()

Browse Source
This commit is contained in:
Aaron Piotrowski 2017-03-21 18:45:23 -05:00
parent 34d07fcd34
commit 9bf978ad01
3 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
lib/Worker/AbstractWorker.php
View File

@ -50,7 +50,7 @@ abstract class AbstractWorker implements Worker {
unset($this->jobQueue[$id]); unset($this->jobQueue[$id]);
if (!empty($this->jobQueue)) { if (!empty($this->jobQueue)) {
$this->context->receive()->when($this->when); $this->context->receive()->onResolve($this->when);
} }
$deferred->resolve($data->promise()); $deferred->resolve($data->promise());
@ -105,7 +105,7 @@ abstract class AbstractWorker implements Worker {
*/ */
private function doEnqueue(Task $task): \Generator { private function doEnqueue(Task $task): \Generator {
if (empty($this->jobQueue)) { if (empty($this->jobQueue)) {
$this->context->receive()->when($this->when); $this->context->receive()->onResolve($this->when);
} }
try { try {

2
lib/Worker/Internal/TaskRunner.php
View File

@ -52,7 +52,7 @@ class TaskRunner {
$result = new Failure($exception); $result = new Failure($exception);
} }
$result->when(function ($exception, $value) use ($job) { $result->onResolve(function ($exception, $value) use ($job) {
if ($exception) { if ($exception) {
$result = new TaskFailure($job->getId(), $exception); $result = new TaskFailure($job->getId(), $exception);
} else { } else {

4
test/Sync/AbstractParcelTest.php
View File

@ -42,7 +42,7 @@ abstract class AbstractParcelTest extends TestCase {
$callback->method('__invoke') $callback->method('__invoke')
->with($this->identicalTo(null), $this->identicalTo(1)); ->with($this->identicalTo(null), $this->identicalTo(1));
$awaitable->when($callback); $awaitable->onResolve($callback);
$awaitable = $parcel->synchronized(function ($value) { $awaitable = $parcel->synchronized(function ($value) {
$this->assertSame(1, $value); $this->assertSame(1, $value);
@ -54,7 +54,7 @@ abstract class AbstractParcelTest extends TestCase {
$callback->method('__invoke') $callback->method('__invoke')
->with($this->identicalTo(null), $this->identicalTo(2)); ->with($this->identicalTo(null), $this->identicalTo(2));
$awaitable->when($callback); $awaitable->onResolve($callback);
} }
/** /**