Fix cs

Author: joelwurtz

src/Deferred.php

@@ -7,7 +7,7 @@
 use Psr\Http\Message\ResponseInterface;
 
 /**
- * A deferred allow to return a promise which has not been resolved yet
+ * A deferred allow to return a promise which has not been resolved yet.
  */
 class Deferred implements Promise
 {
@@ -36,9 +36,9 @@ public function __construct(callable $waitCallback)
      */
     public function then(callable $onFulfilled = null, callable $onRejected = null)
     {
-        $deferred = new Deferred($this->waitCallback);
+        $deferred = new self($this->waitCallback);
 
-        $this->onFulfilledCallbacks[] = function (ResponseInterface $response) use($onFulfilled, $deferred) {
+        $this->onFulfilledCallbacks[] = function (ResponseInterface $response) use ($onFulfilled, $deferred) {
             try {
                 if (null !== $onFulfilled) {
                     $response = $onFulfilled($response);
@@ -49,7 +49,7 @@ public function then(callable $onFulfilled = null, callable $onRejected = null)
             }
         };
 
-        $this->onRejectedCallbacks[] = function (Exception $exception) use($onRejected, $deferred) {
+        $this->onRejectedCallbacks[] = function (Exception $exception) use ($onRejected, $deferred) {
             try {
                 if (null !== $onRejected) {
                     $response = $onRejected($exception);
@@ -75,11 +75,11 @@ public function getState()
     }
 
     /**
-     * Resolve this deferred with a Response
+     * Resolve this deferred with a Response.
      */
     public function resolve(ResponseInterface $response)
     {
-        if ($this->state !== self::PENDING) {
+        if (self::PENDING !== $this->state) {
             return;
         }
 
@@ -92,11 +92,11 @@ public function resolve(ResponseInterface $response)
     }
 
     /**
-     * Reject this deferred with an Exception
+     * Reject this deferred with an Exception.
      */
     public function reject(Exception $exception)
     {
-        if ($this->state !== self::PENDING) {
+        if (self::PENDING !== $this->state) {
             return;
         }
 
@@ -113,7 +113,7 @@ public function reject(Exception $exception)
      */
     public function wait($unwrap = true)
     {
-        if ($this->state === self::PENDING) {
+        if (self::PENDING === $this->state) {
             $callback = $this->waitCallback;
             $callback();
         }
@@ -122,7 +122,7 @@ public function wait($unwrap = true)
             return;
         }
 
-        if ($this->state === self::FULFILLED) {
+        if (self::FULFILLED === $this->state) {
             return $this->value;
         }
 

src/Plugin/RetryPlugin.php

@@ -78,7 +78,7 @@ public function handleRequest(RequestInterface $request, callable $next, callabl
         $chainIdentifier = spl_object_hash((object) $first);
 
         $promise = $next($request);
-        $deferred = new Deferred(function () use($promise) {
+        $deferred = new Deferred(function () use ($promise) {
             $promise->wait(false);
         });