mpyw / php-hyper-builtin-server

src/BuiltinServerFactory.php

Doc Comments +4 added lines

@@ -59,6 +59,10 @@
         });
     }
 
+    /**
+     * @param string $host
+     * @param integer $retry
+     */
     protected function createInternalWithRetryAsync($host, $docroot, $router, $retry)
     {
         return $this

Spacing +5 added lines, -5 removed lines

@@ -28,20 +28,20 @@ 
         $process = new BuiltinServer($host, $docroot, $router, $this->php);
 
         $process->start($this->loop);
-        $process->on('exit', function ($code) use ($deferred) {
+        $process->on('exit', function($code) use ($deferred) {
             $this->stderr->write("Process exit with code $code\n");
             $deferred->reject();
         });
 
         $process->stdin->close();
         $process->stdout->close();
-        $process->stderr->on('data', function ($output) use ($deferred) {
+        $process->stderr->on('data', function($output) use ($deferred) {
             $this->stderr->write($output);
             $deferred->reject();
         });
 
         $timer = new Deferred;
-        $this->loop->addTimer(0.05, function () use ($timer, $process) {
+        $this->loop->addTimer(0.05, function() use ($timer, $process) {
             if (DIRECTORY_SEPARATOR === '\\') {
                 // Pipes opened by proc_open() can break stream_select() loop in Windows.
                 // This fix might do the trick...
@@ -53,7 +53,7 @@ 
         return \React\Promise\race([
             $deferred->promise(),
             $timer->promise(),
-        ])->then(null, function () use ($process) {
+        ])->then(null, function() use ($process) {
             $process->terminate();
             return new RejectedPromise;
         });
@@ -63,7 +63,7 @@ 
     {
         return $this
         ->createInternalAsync($host, $docroot, $router)
-        ->then(null, function ($e) use ($host, $docroot, $router, $retry) {
+        ->then(null, function($e) use ($host, $docroot, $router, $retry) {
             if ($retry < 1) {
                 throw new \RuntimeException('Failed to launch server.');
             }

src/Internal/Sink.php

Spacing +2 added lines, -2 removed lines

@@ -14,14 +14,14 @@
     public function __construct(ConnectionInterface $src)
     {
         $this->src = $src;
-        $src->on('data', function ($data) {
+        $src->on('data', function($data) {
             $this->buffer .= $data;
             if ($this->dst) {
                 $this->dst->write($this->buffer);
                 $this->buffer = '';
             }
         });
-        $src->on('end', function () {
+        $src->on('end', function() {
             $this->end = true;
             if ($this->dst) {
                 $this->dst->end();

src/Internal/ConnectionHandler.php

Spacing +2 added lines, -2 removed lines

@@ -18,13 +18,13 @@
     public function __invoke(ConnectionInterface $conn)
     {
         $sink = new Sink($conn);
-        $this->master->queue->executeAsync(function (BuiltinServer $process) use ($conn, $sink) {
+        $this->master->queue->executeAsync(function(BuiltinServer $process) use ($conn, $sink) {
             $deferred = new Deferred;
             try {
                 $child = new Stream($process->getSocketClient(), $this->master->loop);
                 $sink->pipe($child);
                 $child->pipe($conn);
-                $child->on('close', function () use ($deferred) {
+                $child->on('close', function() use ($deferred) {
                     $deferred->resolve();
                 });
             } catch (\RuntimeException $e) {

src/Internal/Queue.php

Spacing +2 added lines, -2 removed lines

@@ -12,7 +12,7 @@ 
         if (!$processes) {
             throw new \LengthException('At least 1 process required.');
         }
-        array_walk($processes, function (BuiltinServer $process) {
+        array_walk($processes, function(BuiltinServer $process) {
             $this->processes[spl_object_hash($process)] = $process;
         });
     }
@@ -28,7 +28,7 @@ 
     {
         $process = current($this->processes);
         unset($this->processes[spl_object_hash($process)]);
-        $promisor($process)->always(function () use ($process) {
+        $promisor($process)->always(function() use ($process) {
             $this->processes[spl_object_hash($process)] = $process;
             $this->dequeue();
         });