dazzle-php / mysql

src/MySQL/Database.php

Spacing +15 added lines, -15 removed lines

@@ -105,12 +105,12 @@ 
             $options = $this->config;
             $streamRef = $this->stream;
 
-            $errorHandler = function ($reason) use ($reject) {
+            $errorHandler = function($reason) use ($reject) {
                 $this->state = self::STATE_AUTH_FAILED;
                 return $reject($reason);
             };
 
-            $connectedHandler = function ($serverOptions) use ($resolve) {
+            $connectedHandler = function($serverOptions) use ($resolve) {
                 $this->state = self::STATE_AUTH_SUCCEEDED;
                 $this->serverOptions = $serverOptions;
                 return $resolve($serverOptions);
@@ -118,11 +118,11 @@ 
 
             $this
                 ->connect()
-                ->then(function ($stream) use (&$streamRef, $options, $errorHandler, $connectedHandler) {
+                ->then(function($stream) use (&$streamRef, $options, $errorHandler, $connectedHandler) {
                     $streamRef = $stream;
 
-                    $stream->on('error', [ $this, 'handleConnectionError' ]);
-                    $stream->on('close', [ $this, 'handleConnectionClosed' ]);
+                    $stream->on('error', [$this, 'handleConnectionError']);
+                    $stream->on('close', [$this, 'handleConnectionClosed']);
 
                     $parser = $this->parser = new ProtocolParser($stream, $this->executor);
 
@@ -135,7 +135,7 @@ 
                     //$parser->on('close', $closeHandler);
                     $parser->start();
 
-                }, [ $this, 'handleConnectionError' ]);
+                }, [$this, 'handleConnectionError']);
         });
     }
 
@@ -150,8 +150,8 @@ 
                 ->doCommand(new QuitCommand($this))
                 ->on('success', function() use($resolve) {
                     $this->state = self::STATE_STOPPED;
-                    $this->emit('end', [ $this ]);
-                    $this->emit('close', [ $this ]);
+                    $this->emit('end', [$this]);
+                    $this->emit('close', [$this]);
                     $resolve($this);
                 });
             $this->state = self::STATE_CLOSEING;
@@ -175,15 +175,15 @@ 
         $query->bindParamsFromArray($sqlParams);
         $this->doCommand($command);
 
-        $command->on('results', function ($rows, $command) use ($promise) {
+        $command->on('results', function($rows, $command) use ($promise) {
             return $command->hasError()
                 ? $promise->reject($command->getError())
                 : $promise->resolve($command);
         });
-        $command->on('error', function ($err, $command) use ($promise) {
+        $command->on('error', function($err, $command) use ($promise) {
             return $promise->reject($err);
         });
-        $command->on('success', function ($command) use ($promise) {
+        $command->on('success', function($command) use ($promise) {
             return $command->hasError()
                 ? $promise->reject($command->getError())
                 : $promise->resolve($command);
@@ -197,10 +197,10 @@ 
         $promise = new Promise();
 
         $this->doCommand(new PingCommand($this))
-            ->on('error', function ($reason) use ($promise) {
+            ->on('error', function($reason) use ($promise) {
                 return $promise->reject($reason);
             })
-            ->on('success', function () use ($promise) {
+            ->on('success', function() use ($promise) {
                 return $promise->resolve();
             });
     }
@@ -234,7 +234,7 @@ 
 
     public function handleConnectionError($err)
     {
-        $this->emit('error', [ $err, $this ]);
+        $this->emit('error', [$err, $this]);
     }
 
     public function handleConnectionClosed()
@@ -242,7 +242,7 @@ 
         if ($this->state < self::STATE_CLOSEING)
         {
             $this->state = self::STATE_STOPPED;
-            $this->emit('error', [ new RuntimeException('mysql server has gone away'), $this ]);
+            $this->emit('error', [new RuntimeException('mysql server has gone away'), $this]);
         }
     }