kadet1090 / nucleus

Xml/XmlStream.php

Spacing +13 added lines, -13 removed lines

@@ -91,35 +91,35 @@ 
         parent::__construct($transport);
         $this->setParser($parser);
 
-        $this->on('close', function () { $this->_isOpened = false; });
-        $this->on('element', function (Error $element) {
+        $this->on('close', function() { $this->_isOpened = false; });
+        $this->on('element', function(Error $element) {
             $this->handleError($element);
         }, with\instance(Error::class));
     }
 
     public function setParser(XmlParser $parser)
     {
-        if($this->_parser) {
-            $this->removeListener('data', [ $this->_parser, 'parse' ]);
+        if ($this->_parser) {
+            $this->removeListener('data', [$this->_parser, 'parse']);
         }
 
         $this->_parser = $parser;
 
-        $this->_parser->on('parse.begin', function (XmlElement $stream) {
+        $this->_parser->on('parse.begin', function(XmlElement $stream) {
             $this->_inbound = $stream;
-            $this->emit('stream.open', [ $stream ]);
+            $this->emit('stream.open', [$stream]);
         }, with\argument(1, with\equals(0)));
 
-        $this->_parser->on('parse.end', function (XmlElement $stream) {
-            $this->emit('stream.close', [ $stream ]);
+        $this->_parser->on('parse.end', function(XmlElement $stream) {
+            $this->emit('stream.close', [$stream]);
             $this->_inbound = null;
         }, with\argument(1, with\equals(0)));
 
-        $this->_parser->on('element', function (...$arguments) {
+        $this->_parser->on('element', function(...$arguments) {
             $this->emit('element', $arguments);
         });
 
-        $this->on('data', [ $this->_parser, 'parse' ]);
+        $this->on('data', [$this->_parser, 'parse']);
     }
 
     /**
@@ -130,11 +130,11 @@ 
      */
     public function write($data)
     {
-        if($data instanceof XmlElement) {
+        if ($data instanceof XmlElement) {
             $this->_outbound->append($data);
         }
 
-        $this->emit('send.'.($data instanceof XmlElement ? 'element' : 'text'), [ $data ]);
+        $this->emit('send.' . ($data instanceof XmlElement ? 'element' : 'text'), [$data]);
 
         return parent::write($data);
     }
@@ -195,7 +195,7 @@ 
 
     private function handleError(Error $element)
     {
-        if ($this->emit('stream.error', [ $element ])) {
+        if ($this->emit('stream.error', [$element])) {
             throw new StreamErrorException($element);
         }
 

XmppClient.php

Spacing +6 added lines, -6 removed lines

@@ -131,12 +131,12 @@ 
 
         $this->applyOptions($options);
 
-        $this->on('element', function (Features $element) {
+        $this->on('element', function(Features $element) {
             $this->_features = $element;
             $this->emit('features', [$element]);
         }, Features::class);
 
-        $this->on('close', function (Features $element) {
+        $this->on('close', function(Features $element) {
             $this->state = 'disconnected';
         }, Features::class);
     }
@@ -196,7 +196,7 @@ 
         $this->state = 'bound';
 
         $queue = new ObservableCollection();
-        $queue->on('empty', function () {
+        $queue->on('empty', function() {
             $this->state = 'ready';
         });
 
@@ -220,7 +220,7 @@ 
             $this->_container->set(get_class($module), $module);
 
             $this->register($module, array_merge(class_implements($module), array_slice(class_parents($module), 1)));
-        } elseif(is_array($alias)) {
+        } elseif (is_array($alias)) {
             foreach ($alias as $name) {
                 if (!$this->has($name)) {
                     $this->register($module, $name);
@@ -256,7 +256,7 @@ 
     //region Parser
     public function setParser(XmlParser $parser)
     {
-        if($this->state !== "disconnected") {
+        if ($this->state !== "disconnected") {
             throw new \BadMethodCallException('Parser can be changed only when client is disconnected.');
         }
 
@@ -284,7 +284,7 @@ 
             ));
         }
 
-        $this->_connector->on('connect', function ($stream) {
+        $this->_connector->on('connect', function($stream) {
             return $this->handleConnect($stream);
         });
     }

Doc Comments +1 added lines, -1 removed lines

@@ -207,7 +207,7 @@
      * Registers module in client's dependency container.
      *
      * @param ClientModuleInterface $module Module to be registered
-     * @param bool|string|array     $alias  Module alias, class name by default.
+     * @param string|boolean     $alias  Module alias, class name by default.
      *                                      `true` for aliasing interfaces and parents too,
      *                                      `false` for aliasing as class name only
      *                                      array for multiple aliases,