comodojo / daemon

src/Comodojo/Daemon/Worker/Manager.php

Indentation +2 added lines, -2 removed lines

@@ -29,7 +29,7 @@ 
  * THE SOFTWARE.
  */
 
- class Manager implements Iterator, Countable {
+    class Manager implements Iterator, Countable {
 
     use IteratorTrait;
     use CountableTrait;
@@ -274,4 +274,4 @@ 
 
     }
 
- }
+    }

src/Comodojo/Daemon/Socket/MethodsInjector.php

Spacing +4 added lines, -4 removed lines

@@ -23,7 +23,7 @@ 
             RpcMethod::create("worker.list", function($params, $daemon) {
                 $workers = $daemon->getWorkers()->get();
                 $wlist = [];
-                foreach ($workers as $worker => $opts) {
+                foreach ( $workers as $worker => $opts ) {
                     $wlist[] = [
                         'name' => $worker,
                         'looptime' => $opts->getLoopTime(),
@@ -44,7 +44,7 @@ 
             ->setDescription("Get info about installed worker(s)")
             ->setReturnType('array')
             ->addSignature()
-            ->addParameter('string','name')
+            ->addParameter('string', 'name')
             ->setReturnType('int')
         );
 
@@ -56,7 +56,7 @@ 
             ->setDescription("Pause installed worker(s)")
             ->setReturnType('array')
             ->addSignature()
-            ->addParameter('string','name')
+            ->addParameter('string', 'name')
             ->setReturnType('boolean')
         );
 
@@ -68,7 +68,7 @@ 
             ->setDescription("Resume installed worker(s)")
             ->setReturnType('array')
             ->addSignature()
-            ->addParameter('string','name')
+            ->addParameter('string', 'name')
             ->setReturnType('boolean')
         );
 

src/Comodojo/Daemon/Socket/Server.php

Indentation +2 added lines, -2 removed lines

@@ -263,9 +263,9 @@
 
                     if ( $message === null ) {
                     // if ($message == null) {
-                         $this->hangup($client);
+                            $this->hangup($client);
                     } else if ( $message === false ) {
-                         continue;
+                            continue;
                     } else {
                         $output = $this->serve($message);
                         $this->write($client, $output);