dazzle-php / pgsql

src/PgSQL/Transaction.php

Spacing +4 added lines, -4 removed lines

@@ -82,15 +82,15 @@ 
 
         $promise = new Promise();
 
-        $this->on('error', function ($trans, $err) use ($promise) {
+        $this->on('error', function($trans, $err) use ($promise) {
             return $promise->reject($err);
         });
-        $this->on('success', function ($trans) use ($promise) {
+        $this->on('success', function($trans) use ($promise) {
             return $promise->resolve();
         });
 
         $this->open = false;
-        $this->emit('commit', [ $this, $this->queue ]);
+        $this->emit('commit', [$this, $this->queue]);
         $this->queue = [];
 
         return $promise;
@@ -108,7 +108,7 @@ 
         }
 
         $this->open = false;
-        $this->emit('rollback', [ $this ]);
+        $this->emit('rollback', [$this]);
         $this->queue = [];
 
         return Promise::doResolve();

src/PgSQL/Database.php

Spacing +10 added lines, -10 removed lines

@@ -18,42 +18,42 @@ 
     /**
      * @var int
      */
-    const STATE_INIT                 = 0;
+    const STATE_INIT = 0;
 
     /**
      * @var int
      */
-    const STATE_CONNECT_PENDING      = 4;
+    const STATE_CONNECT_PENDING = 4;
 
     /**
      * @var int
      */
-    const STATE_CONNECT_FAILED       = 2;
+    const STATE_CONNECT_FAILED = 2;
 
     /**
      * @var int
      */
-    const STATE_CONNECT_SUCCEEDED    = 6;
+    const STATE_CONNECT_SUCCEEDED = 6;
 
     /**
      * @var int
      */
-    const STATE_AUTH_PENDING         = 5;
+    const STATE_AUTH_PENDING = 5;
 
     /**
      * @var int
      */
-    const STATE_AUTH_FAILED          = 3;
+    const STATE_AUTH_FAILED = 3;
 
     /**
      * @var int
      */
-    const STATE_AUTH_SUCCEEDED       = 7;
+    const STATE_AUTH_SUCCEEDED = 7;
 
     /**
      * @var int
      */
-    const STATE_DISCONNECT_PENDING   = 8;
+    const STATE_DISCONNECT_PENDING = 8;
 
     /**
      * @var int
@@ -243,10 +243,10 @@ 
         $trans->on('commit', function(TransactionInterface $trans, array $queue) {
             $this->commitTransaction($queue)->then(
                 function() use($trans) {
-                    return $trans->emit('success', [ $trans ]);
+                    return $trans->emit('success', [$trans]);
                 },
                 function($ex) use($trans) {
-                    return $trans->emit('error', [ $trans, $ex ]);
+                    return $trans->emit('error', [$trans, $ex]);
                 }
             );
             $this->transBox->remove($trans);