dazzle-php / socket

src/Socket/SocketListener.php

Spacing +8 added lines, -8 removed lines

@@ -203,7 +203,7 @@ 
     {
         $endpoint = explode('://', $this->getLocalEndpoint(), 2);
 
-        return isset($endpoint[0]) ? $endpoint[0]:'';
+        return isset($endpoint[0]) ? $endpoint[0] : '';
     }
 
     /**
@@ -299,9 +299,9 @@ 
 
         $this->started = false;
 
-        $this->emit('close', [ $this ]);
+        $this->emit('close', [$this]);
         $this->handleClose();
-        $this->emit('done', [ $this ]);
+        $this->emit('done', [$this]);
     }
 
     /**
@@ -333,7 +333,7 @@ 
 
             if (isset($this->loop))
             {
-                $this->loop->addReadStream($this->socket, [ $this, 'handleConnect' ]);
+                $this->loop->addReadStream($this->socket, [$this, 'handleConnect']);
             }
         }
     }
@@ -460,7 +460,7 @@ 
 
         if ($socket === false)
         {
-            $this->emit('error', [ $this, new ReadException('Socket could not accept new connection.') ]);
+            $this->emit('error', [$this, new ReadException('Socket could not accept new connection.')]);
             return;
         }
 
@@ -474,7 +474,7 @@ 
                 'ssl_method' => $this->config['ssl_method'],
             ]);
 
-            $this->emit('connect', [ $this, $client ]);
+            $this->emit('connect', [$this, $client]);
         }
         catch (Error $ex)
         {}
@@ -484,7 +484,7 @@ 
         if ($ex !== null)
         {
             $this->handleDisconnect($socket);
-            $this->emit('error', [ $this, new ReadException('Socket could not wrap new connection!') ]);
+            $this->emit('error', [$this, new ReadException('Socket could not wrap new connection!')]);
         }
     }
 
@@ -572,7 +572,7 @@ 
                         $count = count($parts);
                         $port = $parts[$count - 1];
                         unset($parts[$count - 1]);
-                        $endpoint = $transport.'[' . implode(':', $parts) . ']:' . $port;
+                        $endpoint = $transport . '[' . implode(':', $parts) . ']:' . $port;
                     }
                     else
                     {

src/Socket/Socket.php

Spacing +11 added lines, -11 removed lines

@@ -354,7 +354,7 @@ 
         if ($ex !== null)
         {
             $this->close();
-            $this->emit('error', [ $this, $ex ]);
+            $this->emit('error', [$this, $ex]);
         }
     }
 
@@ -373,8 +373,8 @@ 
 
             if ($data !== '' && $data !== false)
             {
-                $this->emit('data', [ $this, $data ]);
-                $this->emit('end', [ $this ]);
+                $this->emit('data', [$this, $data]);
+                $this->emit('end', [$this]);
             }
 
             if ($data === '' || $data === false || !is_resource($this->resource) || feof($this->resource))
@@ -389,7 +389,7 @@ 
 
         if ($ex !== null)
         {
-            $this->emit('error', [ $this, $ex ]);
+            $this->emit('error', [$this, $ex]);
         }
     }
 
@@ -413,7 +413,7 @@ 
 
         if ($ex !== null)
         {
-            $this->emit('error', [ $this, $ex ]);
+            $this->emit('error', [$this, $ex]);
         }
     }
 
@@ -443,8 +443,8 @@ 
     protected function getHandleReadFunction()
     {
         return $this->config['ssl'] === true && !$this->isEncrypted()
-            ? [ $this, 'handleEncrypt' ]
-            : [ $this, 'handleRead' ];
+            ? [$this, 'handleEncrypt']
+            : [$this, 'handleRead'];
     }
 
     /**
@@ -455,8 +455,8 @@ 
     protected function getHandleWriteFunction()
     {
         return $this->config['ssl'] === true && !$this->isEncrypted()
-            ? [ $this, 'handleEncrypt' ]
-            : [ $this, 'handleWrite' ];
+            ? [$this, 'handleEncrypt']
+            : [$this, 'handleWrite'];
     }
 
     /**
@@ -493,7 +493,7 @@ 
      */
     private function parseEndpoint($wantPeer = false)
     {
-        $wantIndex = (int)$wantPeer;
+        $wantIndex = (int) $wantPeer;
 
         if (isset($this->cachedEndpoint[$wantIndex]))
         {
@@ -523,7 +523,7 @@ 
                     $count = count($parts);
                     $port = $parts[$count - 1];
                     unset($parts[$count - 1]);
-                    $endpoint = $transport.'[' . implode(':', $parts) . ']:' . $port;
+                    $endpoint = $transport . '[' . implode(':', $parts) . ']:' . $port;
                 }
                 else
                 {