plvhx / promise

src/Context/ContextStack.php

Doc Comments +3 added lines

@@ -23,6 +23,9 @@
         return new static;
     }
 
+    /**
+     * @param \Closure $handler
+     */
     public function store($handler, $value = [])
     {
         if ($handler instanceof \Closure) {

src/FulfilledPromise.php

Spacing +1 added lines, -1 removed lines

@@ -31,7 +31,7 @@
         $q = new Promise();
         $value = $this->value;
 
-        Context\ContextStack::create(new TaskQueue)->store(static function () use ($q, $value, $onFulfilled) {
+        Context\ContextStack::create(new TaskQueue)->store(static function() use ($q, $value, $onFulfilled) {
             if ($q->currentState() === self::STATE_PENDING) {
                 try {
                     $q->resolve($onFulfilled($value));

src/Promise.php

Spacing +3 added lines, -3 removed lines

@@ -85,7 +85,7 @@ 
             $index = $this->state === self::STATE_FULFILLED ? 1 : 2;
 
             Context\ContextStack::create(new TaskQueue)->store(
-            static function () use ($index, $context, $value) {
+            static function() use ($index, $context, $value) {
                 foreach ($context as $c) {
                     self::invokeContext($c, $index, $value);
                 }
@@ -96,12 +96,12 @@ 
             $value->context = array_merge($value->context, $context);
         } else {
             $value->then(
-            static function ($value) use ($context) {
+            static function($value) use ($context) {
                 foreach ($context as $c) {
                     self::invokeContext($c, 1, $value);
                 }
             },
-            static function ($reason) use ($context) {
+            static function($reason) use ($context) {
                 foreach ($context as $c) {
                     self::invokeContext($c, 2, $reason);
                 }

Doc Comments +9 added lines

@@ -78,6 +78,9 @@ 
         $this->cancelCallback = $callback;
     }
 
+    /**
+     * @param integer $state
+     */
     private function validateState($value, $state)
     {
         if ($this->state !== self::STATE_PENDING) {
@@ -273,6 +276,9 @@ 
         }
     }
 
+    /**
+     * @param integer $index
+     */
     private static function invokeContext($context, $index, $value)
     {
         $promise = $context[0];
@@ -294,6 +300,9 @@ 
         }
     }
 
+    /**
+     * @param integer $state
+     */
     private function setState($state)
     {
         if ($state !== self::STATE_PENDING &&

Braces +1 added lines, -2 removed lines

@@ -140,8 +140,7 @@
 
         if ($this->current instanceof PromiseInterface || $this->currentState() === self::STATE_FULFILLED) {
             return $q;
-        }
-        else {
+        } else {
             throw $q instanceof \Exception
                 ? $q
                 : new \Exception($q);

src/RejectedPromise.php

Spacing +1 added lines, -1 removed lines

@@ -31,7 +31,7 @@
         $q = new Promise();
         $reason = $this->reason;
 
-        Context\ContextStack::create(new TaskQueue)->store(static function () use ($q, $reason, $onRejected) {
+        Context\ContextStack::create(new TaskQueue)->store(static function() use ($q, $reason, $onRejected) {
             if ($q->currentState() === self::STATE_PENDING) {
                 try {
                     $q->resolve($onRejected($reason));