edefimov / async-sockets

src/Socket/AsyncSocketFactory.php

Spacing +6 added lines, -8 removed lines

@@ -74,19 +74,17 @@
     {
         switch ($type) {
             case self::SOCKET_CLIENT:
-                $isPersistent  = isset($options[ self::SOCKET_OPTION_IS_PERSISTENT ]) &&
-                                 $options[ self::SOCKET_OPTION_IS_PERSISTENT ];
-                $persistentKey = isset($options[ self::SOCKET_OPTION_PERSISTENT_KEY ]) ?
-                    $options[ self::SOCKET_OPTION_PERSISTENT_KEY ] :
-                    null;
+                $isPersistent  = isset($options[self::SOCKET_OPTION_IS_PERSISTENT]) &&
+                                 $options[self::SOCKET_OPTION_IS_PERSISTENT];
+                $persistentKey = isset($options[self::SOCKET_OPTION_PERSISTENT_KEY]) ?
+                    $options[self::SOCKET_OPTION_PERSISTENT_KEY] : null;
 
                 return $isPersistent ?
-                    new PersistentClientSocket($persistentKey) :
-                    new ClientSocket();
+                    new PersistentClientSocket($persistentKey) : new ClientSocket();
             case self::SOCKET_SERVER:
                 return new ServerSocket();
             default:
-                throw new \InvalidArgumentException("Unexpected type {$type} used in " . __FUNCTION__);
+                throw new \InvalidArgumentException("Unexpected type {$type} used in ".__FUNCTION__);
         }
     }
 

src/Socket/PersistentClientSocket.php

Spacing +1 added lines, -1 removed lines

@@ -40,7 +40,7 @@
     protected function createSocketResource($address, $context)
     {
         $resource = stream_socket_client(
-            $address . ($this->persistentKey ? '/' . $this->persistentKey : ''),
+            $address.($this->persistentKey ? '/'.$this->persistentKey : ''),
             $errno,
             $errstr,
             null,

src/Socket/Io/DatagramClientIo.php

Spacing +1 added lines, -1 removed lines

@@ -35,7 +35,7 @@
         parent::__construct($socket, 0);
         if ($remoteAddress) {
             $components = parse_url($remoteAddress);
-            $this->remoteAddress = $components['host'] . ':' . $components['port'];
+            $this->remoteAddress = $components['host'].':'.$components['port'];
         }
     }
 

src/Socket/AbstractSocket.php

Spacing +1 added lines, -1 removed lines

@@ -182,7 +182,7 @@
             'unix' => self::SOCKET_TYPE_UNIX,
         ];
 
-        $regexp = '#^('. implode('|', array_keys($map)) . ')_socket$#';
+        $regexp = '#^('.implode('|', array_keys($map)).')_socket$#';
         foreach ($parts as $part) {
             if (preg_match($regexp, $part, $pockets)) {
                 return $map[$pockets[1]];