dazzle-php / channel-zmq

src/Channel-Zmq/Connection/ConnectionPool.php

Doc Comments +1 added lines, -1 removed lines

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

Spacing +1 added lines, -1 removed lines

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

src/Channel-Zmq/ZmqModel.php

Doc Comments +3 added lines, -3 removed lines

@@ -493,7 +493,7 @@ 
 
     /**
      * @param int $type
-     * @return int string
+     * @return string string
      */
     private function getSocketConnectorType($type)
     {
@@ -510,7 +510,7 @@ 
 
     /**
      * @param int $type
-     * @return int string
+     * @return string string
      */
     private function getSocketDisconnectorType($type)
     {
@@ -545,7 +545,7 @@ 
 
     /**
      * @param Connection $conn
-     * @param $message
+     * @param string[] $message
      * @return mixed
      */
     private function recvMessage(Connection $conn, $message)

Spacing +18 added lines, -18 removed lines

@@ -164,11 +164,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;
@@ -176,7 +176,7 @@ 
         $this->id = $id;
         $this->endpoint = $endpoint;
         $this->type = $type;
-        $this->hosts = is_array($hosts) ? $hosts : [ $hosts ];
+        $this->hosts = is_array($hosts) ? $hosts : [$hosts];
         $this->flags = $flags;
         $this->options = $options;
         $this->isConnected = false;
@@ -189,7 +189,7 @@ 
         $this->buffer = $this->getBuffer();
         $this->connectionPool = $this->getConnectionPool();
 
-        $this->setEventListener('messages', [ $this, 'onMessages' ]);
+        $this->setEventListener('messages', [$this, 'onMessages']);
     }
 
     /**
@@ -199,7 +199,7 @@ 
     {
         $this->stop();
 
-        $this->removeEventListener('messages', [ $this, 'onMessages' ]);
+        $this->removeEventListener('messages', [$this, 'onMessages']);
 
         unset($this->context);
         unset($this->id);
@@ -234,7 +234,7 @@ 
         $connect = $this->connectCallback;
         if (!$this->socket->$connect($this->endpoint))
         {
-            $this->emit('error', [ new ExecutionException('socket not connected.') ]);
+            $this->emit('error', [new ExecutionException('socket not connected.')]);
             return false;
         }
 
@@ -292,7 +292,7 @@ 
     {
         $status = $this->sendMessage($id, self::COMMAND_MESSAGE, $message, $flags);
 
-        $this->emit('send', [ $id, (array) $message ]);
+        $this->emit('send', [$id, (array) $message]);
 
         return $status;
     }
@@ -313,7 +313,7 @@ 
 
         foreach ($conns as $conn)
         {
-            $this->emit('send', [ $conn, (array) $message ]);
+            $this->emit('send', [$conn, (array) $message]);
         }
 
         return $statuses;
@@ -550,7 +550,7 @@ 
      */
     private function recvMessage(Connection $conn, $message)
     {
-        $this->emit('recv', [ $conn->id, $message ]);
+        $this->emit('recv', [$conn->id, $message]);
     }
 
     /**
@@ -565,7 +565,7 @@ 
 
         if ($this->connectionPool->setConnection($conn->id))
         {
-            $this->emit('connect', [ $conn->getId() ]);
+            $this->emit('connect', [$conn->getId()]);
         }
 
         if ($this->type === self::BINDER)
@@ -604,7 +604,7 @@ 
         if ($this->hTimer === null && $this->flags['enableHeartbeat'])
         {
             $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 === self::CONNECTOR)
                 {
@@ -628,7 +628,7 @@ 
 
         foreach ($deleted as $deletedid)
         {
-            $this->emit('disconnect', [ $deletedid ]);
+            $this->emit('disconnect', [$deletedid]);
         }
     }
 
@@ -673,7 +673,7 @@ 
             }
             else if (!is_array($message))
             {
-                $message = [ $message ];
+                $message = [$message];
             }
 
             $frame = array_merge($frame, $message);
@@ -734,8 +734,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;
                 });

src/Channel-Zmq/ZmqDealer.php

Spacing +4 added lines, -4 removed lines

@@ -24,7 +24,7 @@ 
         $type = $multipartMessage[2];
         $message = array_slice($multipartMessage, 3);
 
-        return [ $id, $type, $message ];
+        return [$id, $type, $message];
     }
 
     /**
@@ -37,7 +37,7 @@ 
         $type = $multipartMessage[2];
         $message = array_slice($multipartMessage, 3);
 
-        return [ $id, $type, $message ];
+        return [$id, $type, $message];
     }
 
     /**
@@ -47,7 +47,7 @@ 
      */
     protected function prepareBinderMessage($id, $type)
     {
-        return [ $id, $this->id, $type ];
+        return [$id, $this->id, $type];
     }
 
     /**
@@ -57,6 +57,6 @@ 
      */
     protected function prepareConnectorMessage($id, $type)
     {
-        return [ $id, $this->id, $type ];
+        return [$id, $this->id, $type];
     }
 }