From 9bf978ad01d4e2eb2be30ad259b3a737ddfa393f Mon Sep 17 00:00:00 2001
From: Aaron Piotrowski <aaron@trowski.com>
Date: Tue, 21 Mar 2017 18:45:23 -0500
Subject: [PATCH] =?UTF-8?q?when()=20=E2=86=92=20onResolve()?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 lib/Worker/AbstractWorker.php      | 4 ++--
 lib/Worker/Internal/TaskRunner.php | 2 +-
 test/Sync/AbstractParcelTest.php   | 4 ++--
 3 files changed, 5 insertions(+), 5 deletions(-)

diff --git a/lib/Worker/AbstractWorker.php b/lib/Worker/AbstractWorker.php
index f79a2c1..1c96399 100644
--- a/lib/Worker/AbstractWorker.php
+++ b/lib/Worker/AbstractWorker.php
@@ -50,7 +50,7 @@ abstract class AbstractWorker implements Worker {
             unset($this->jobQueue[$id]);
             
             if (!empty($this->jobQueue)) {
-                $this->context->receive()->when($this->when);
+                $this->context->receive()->onResolve($this->when);
             }
             
             $deferred->resolve($data->promise());
@@ -105,7 +105,7 @@ abstract class AbstractWorker implements Worker {
      */
     private function doEnqueue(Task $task): \Generator {
         if (empty($this->jobQueue)) {
-            $this->context->receive()->when($this->when);
+            $this->context->receive()->onResolve($this->when);
         }
         
         try {
diff --git a/lib/Worker/Internal/TaskRunner.php b/lib/Worker/Internal/TaskRunner.php
index 767fa23..9a61da8 100644
--- a/lib/Worker/Internal/TaskRunner.php
+++ b/lib/Worker/Internal/TaskRunner.php
@@ -52,7 +52,7 @@ class TaskRunner {
                 $result = new Failure($exception);
             }
             
-            $result->when(function ($exception, $value) use ($job) {
+            $result->onResolve(function ($exception, $value) use ($job) {
                 if ($exception) {
                     $result = new TaskFailure($job->getId(), $exception);
                 } else {
diff --git a/test/Sync/AbstractParcelTest.php b/test/Sync/AbstractParcelTest.php
index f0d487c..027a81a 100644
--- a/test/Sync/AbstractParcelTest.php
+++ b/test/Sync/AbstractParcelTest.php
@@ -42,7 +42,7 @@ abstract class AbstractParcelTest extends TestCase {
         $callback->method('__invoke')
             ->with($this->identicalTo(null), $this->identicalTo(1));
 
-        $awaitable->when($callback);
+        $awaitable->onResolve($callback);
 
         $awaitable = $parcel->synchronized(function ($value) {
             $this->assertSame(1, $value);
@@ -54,7 +54,7 @@ abstract class AbstractParcelTest extends TestCase {
         $callback->method('__invoke')
             ->with($this->identicalTo(null), $this->identicalTo(2));
 
-        $awaitable->when($callback);
+        $awaitable->onResolve($callback);
     }
 
     /**