dazzle-php / channel-socket

src/Channel-Socket/Connection/ConnectionPool.php

Doc Comments +1 added lines, -1 removed lines

@@ -201,7 +201,7 @@
     }
 
     /**
-     * @param $id
+     * @param string $id
      * @return bool
      */
     public function registerHeartbeat($id)

Spacing +1 added lines, -1 removed lines

@@ -239,7 +239,7 @@
     public function resetNow()
     {
         $this->now = function() {
-            return round(microtime(true)*1000);
+            return round(microtime(true) * 1000);
         };
     }
 

src/Channel-Socket/Socket.php

Doc Comments +4 added lines, -3 removed lines

@@ -381,7 +381,7 @@ 
     /**
      * @param string $id
      * @param string $type
-     * @return string[]
+     * @return string
      */
     protected function prepareBinderMessage($id, $type)
     {
@@ -391,7 +391,7 @@ 
     /**
      * @param string $id
      * @param string $type
-     * @return string[]
+     * @return string
      */
     protected function prepareConnectorMessage($id, $type)
     {
@@ -591,6 +591,7 @@ 
     /**
      * @param Connection $conn
      * @param $message[]
+     * @param string[] $message
      * @return mixed
      */
     private function recvMessage(Connection $conn, $message)
@@ -754,7 +755,7 @@ 
      * @param string $type
      * @param string|string[] $message
      * @param int $flags
-     * @return bool
+     * @return integer
      */
     private function sendMessage($id, $type, $message = null, $flags = Channel::MODE_STANDARD)
     {

Spacing +19 added lines, -19 removed lines

@@ -136,11 +136,11 @@ 
         ];
 
         $options = [
-            'bufferSize'            => isset($params['bufferSize']) ? (int)$params['bufferSize'] : 0,
-            'bufferTimeout'         => isset($params['bufferTimeout']) ? (int)$params['bufferTimeout'] : 0,
-            'heartbeatInterval'     => isset($params['heartbeatInterval']) ? (int)$params['heartbeatInterval'] : 200,
-            'heartbeatKeepalive'    => isset($params['heartbeatKeepalive']) ? (int)$params['heartbeatKeepalive'] : 1000,
-            'timeRegisterInterval'  => isset($params['timeRegisterInterval']) ? (int)$params['timeRegisterInterval'] : 400
+            'bufferSize'            => isset($params['bufferSize']) ? (int) $params['bufferSize'] : 0,
+            'bufferTimeout'         => isset($params['bufferTimeout']) ? (int) $params['bufferTimeout'] : 0,
+            'heartbeatInterval'     => isset($params['heartbeatInterval']) ? (int) $params['heartbeatInterval'] : 200,
+            'heartbeatKeepalive'    => isset($params['heartbeatKeepalive']) ? (int) $params['heartbeatKeepalive'] : 1000,
+            'timeRegisterInterval'  => isset($params['timeRegisterInterval']) ? (int) $params['timeRegisterInterval'] : 400
         ];
 
         $this->loop = $loop;
@@ -199,7 +199,7 @@ 
 
         if (!$this->startConnection())
         {
-            $this->emit('error', [ new ExecutionException('socket not connected.') ]);
+            $this->emit('error', [new ExecutionException('socket not connected.')]);
             return false;
         }
 
@@ -240,7 +240,7 @@ 
 
         if (!$this->stopConnection())
         {
-            $this->emit('error', [ new ExecutionException('socket not disconnected.') ]);
+            $this->emit('error', [new ExecutionException('socket not disconnected.')]);
         }
 
         $this->isConnected = false;
@@ -263,7 +263,7 @@ 
 
         if ($status === static::SEND_STATUS_SUCCEEDED)
         {
-            $this->emit('send', [ $id, (array) $message ]);
+            $this->emit('send', [$id, (array) $message]);
         }
 
         return $status > 0;
@@ -285,7 +285,7 @@ 
 
         foreach ($conns as $conn)
         {
-            $this->emit('send', [ $conn, (array) $message ]);
+            $this->emit('send', [$conn, (array) $message]);
         }
 
         return $statuses;
@@ -360,7 +360,7 @@ 
         $type = $multipart[2];
         $message = $multipart[3];
 
-        return [ $id, $type, $message ];
+        return [$id, $type, $message];
     }
 
     /**
@@ -375,7 +375,7 @@ 
         $type = $multipart[2];
         $message = $multipart[3];
 
-        return [ $id, $type, $message ];
+        return [$id, $type, $message];
     }
 
     /**
@@ -563,7 +563,7 @@ 
 
         switch ($type)
         {
-            case self::COMMAND_HEARTBEAT: $this->onRecvHeartbeat($conn);         break;
+            case self::COMMAND_HEARTBEAT: $this->onRecvHeartbeat($conn); break;
             case self::COMMAND_MESSAGE:   $this->onRecvMessage($conn, $message); break;
             default: return;
         }
@@ -595,7 +595,7 @@ 
      */
     private function recvMessage(Connection $conn, $message)
     {
-        $this->emit('recv', [ $conn->id, $message ]);
+        $this->emit('recv', [$conn->id, $message]);
     }
 
     /**
@@ -610,7 +610,7 @@ 
 
         if ($this->connectionPool->setConnection($conn))
         {
-            $this->emit('connect', [ $conn->id ]);
+            $this->emit('connect', [$conn->id]);
         }
 
         if ($this->type === Channel::BINDER)
@@ -686,7 +686,7 @@ 
             switch ($this->type)
             {
                 case Channel::CONNECTOR: $this->destroyConnector(); break;
-                case Channel::BINDER:    $this->destroyBinder();    break;
+                case Channel::BINDER:    $this->destroyBinder(); break;
                 default: return false;
             }
         }
@@ -857,7 +857,7 @@ 
             $this->clearConnectionPool();
 
             $proxy = $this;
-            $this->hTimer = $this->loop->addPeriodicTimer(($this->options['heartbeatInterval']/1000), function() use($proxy) {
+            $this->hTimer = $this->loop->addPeriodicTimer(($this->options['heartbeatInterval'] / 1000), function() use($proxy) {
 
                 if ($proxy->type === Channel::CONNECTOR)
                 {
@@ -893,7 +893,7 @@ 
 
         foreach ($deleted as $deletedid)
         {
-            $this->emit('disconnect', [ $deletedid ]);
+            $this->emit('disconnect', [$deletedid]);
         }
     }
 
@@ -908,8 +908,8 @@ 
         if ($this->rTimer === null && $this->flags['enableHeartbeat'] === true && $this->flags['enableTimeRegister'] === true)
         {
             $proxy = $this;
-            $this->rTimer = $this->loop->addPeriodicTimer(($this->options['timeRegisterInterval']/1000), function() use($proxy) {
-                $now = round(microtime(true)*1000);
+            $this->rTimer = $this->loop->addPeriodicTimer(($this->options['timeRegisterInterval'] / 1000), function() use($proxy) {
+                $now = round(microtime(true) * 1000);
                 $proxy->connectionPool->setNow(function() use($now) {
                     return $now;
                 });

Braces +8 added lines, -4 removed lines

@@ -654,9 +654,11 @@ 
             }
         }
         catch (Error $ex)
-        {}
+        {
+}
         catch (Exception $ex)
-        {}
+        {
+}
 
         if ($ex !== null)
         {
@@ -691,9 +693,11 @@ 
             }
         }
         catch (Error $ex)
-        {}
+        {
+}
         catch (Exception $ex)
-        {}
+        {
+}
 
         if ($ex !== null)
         {

src/Channel-Socket/Buffer/Buffer.php

Spacing +2 added lines, -2 removed lines

@@ -78,7 +78,7 @@ 
             {
                 foreach ($buffer as $message)
                 {
-                    $messages[] = [ $id, $message ];
+                    $messages[] = [$id, $message];
                 }
 
                 $this->messageBuffer[$id] = [];
@@ -93,7 +93,7 @@ 
 
             foreach ($this->messageBuffer[$id] as $message)
             {
-                $messages[] = [ $id, $message ];
+                $messages[] = [$id, $message];
                 $cnt++;
             }