dazzle-php / channel

src/Channel/Channel.php

Doc Comments +8 added lines

@@ -504,6 +504,8 @@ 
     /**
      * @override
      * @inheritDoc
+     * @param ProtocolInterface $message
+     * @param integer $flags
      */
     protected function handleSendAsync($name, $message, $flags = Channel::MODE_DEFAULT)
     {
@@ -522,6 +524,8 @@ 
     /**
      * @override
      * @inheritDoc
+     * @param ProtocolInterface $message
+     * @param integer $flags
      */
     protected function handlePushAsync($name, $message, $flags = Channel::MODE_DEFAULT)
     {
@@ -552,6 +556,8 @@ 
     /**
      * @override
      * @inheritDoc
+     * @param ProtocolInterface $message
+     * @param integer $flags
      */
     protected function handleSendRequest($name, $message, $flags = Channel::MODE_DEFAULT, callable $success = null, callable $failure = null, callable $cancel = null, $timeout = 0.0)
     {
@@ -570,6 +576,8 @@ 
     /**
      * @override
      * @inheritDoc
+     * @param ProtocolInterface $message
+     * @param integer $flags
      */
     protected function handlePushRequest($name, $message, $flags = Channel::MODE_DEFAULT, callable $success = null, callable $failure = null, callable $cancel = null, $timeout = 0.0)
     {

Spacing +8 added lines, -8 removed lines

@@ -431,7 +431,7 @@ 
 
         if ($this->handleReceiveResponse($protocol) || $this->getInput()->handle($sender, $protocol))
         {
-            $this->emit('input', [ $sender, $protocol ]);
+            $this->emit('input', [$sender, $protocol]);
         }
     }
 
@@ -441,7 +441,7 @@ 
      */
     public function pull($sender, ProtocolInterface $protocol)
     {
-        $this->emit('input', [ $sender, $protocol ]);
+        $this->emit('input', [$sender, $protocol]);
     }
 
     /**
@@ -543,7 +543,7 @@ 
         if ($status)
         {
             $this->resolveOrRejectResponse($message->getPid(), $message->getException());
-            $this->emit('output', [ $name, $message ]);
+            $this->emit('output', [$name, $message]);
         }
 
         return $status;
@@ -602,7 +602,7 @@ 
         $request = $this->createRequest($pid, $success, $failure, $cancel, $timeout);
         $this->addRequest($pid, $request);
 
-        $this->emit('output', [ $name, $message ]);
+        $this->emit('output', [$name, $message]);
 
         return $request;
     }
@@ -674,11 +674,11 @@ 
         }
         else if ($exception === TaskIncompleteException::class)
         {
-            $this->cancelRequest($pid, new ThrowableProxy([ $exception, $message ]));
+            $this->cancelRequest($pid, new ThrowableProxy([$exception, $message]));
         }
         else
         {
-            $this->rejectRequest($pid, new ThrowableProxy([ $exception, $message ]));
+            $this->rejectRequest($pid, new ThrowableProxy([$exception, $message]));
         }
 
         return true;
@@ -785,8 +785,8 @@ 
      */
     private function registerEvents()
     {
-        $this->handlers = $this->model->copyEvents($this, [ 'start', 'stop', 'connect', 'disconnect' ]);
-        $this->handlers[] = $this->model->on('recv', [ $this, 'handleReceive' ]);
+        $this->handlers = $this->model->copyEvents($this, ['start', 'stop', 'connect', 'disconnect']);
+        $this->handlers[] = $this->model->on('recv', [$this, 'handleReceive']);
     }
 
     /**

src/Channel/ChannelComposite.php

Doc Comments +4 added lines, -4 removed lines

@@ -577,13 +577,13 @@ 
 
     /**
      * @param string $name
-     * @param string|ProtocolInterface $message
+     * @param ProtocolInterface $message
      * @param int $flags
      * @param callable|null $success
      * @param callable|null $failure
      * @param callable|null $cancel
      * @param float $timeout
-     * @return bool[]
+     * @return boolean
      */
     protected function handleSendRequest($name, $message, $flags = Channel::MODE_DEFAULT, callable $success = null, callable $failure = null, callable $cancel = null, $timeout = 0.0)
     {
@@ -592,7 +592,7 @@ 
 
     /**
      * @param string $name
-     * @param string|ProtocolInterface $message
+     * @param ProtocolInterface $message
      * @param int $flags
      * @param callable|null $success
      * @param callable|null $failure
@@ -665,7 +665,7 @@ 
     }
 
     /**
-     * @return int
+     * @return string
      */
     protected function getNextSuffix()
     {

Spacing +6 added lines, -6 removed lines

@@ -124,8 +124,8 @@ 
         }
 
         $this->buses[$name] = $channel;
-        $this->events[$name] = $channel->copyEvents($this, [ 'connect', 'disconnect' ]);
-        $this->events[$name][] = $channel->on('input', [ $this, 'handleReceive' ]);
+        $this->events[$name] = $channel->copyEvents($this, ['connect', 'disconnect']);
+        $this->events[$name][] = $channel->on('input', [$this, 'handleReceive']);
 
         return $this;
     }
@@ -412,7 +412,7 @@ 
     {
         if ($this->getInput()->handle($sender, $protocol))
         {
-            $this->emit('input', [ $sender, $protocol ]);
+            $this->emit('input', [$sender, $protocol]);
         }
     }
 
@@ -422,7 +422,7 @@ 
      */
     public function pull($sender, ProtocolInterface $protocol)
     {
-        $this->emit('input', [ $sender, $protocol ]);
+        $this->emit('input', [$sender, $protocol]);
     }
 
     /**
@@ -569,7 +569,7 @@ 
 
         if ($status)
         {
-            $this->emit('output', [ $name, $message ]);
+            $this->emit('output', [$name, $message]);
         }
 
         return $status;
@@ -632,7 +632,7 @@ 
 
         if ($status)
         {
-            $this->emit('output', [ $name, $message ]);
+            $this->emit('output', [$name, $message]);
         }
 
         return $status;

src/Channel/Protocol/Protocol.php

Spacing +7 added lines, -7 removed lines

@@ -240,13 +240,13 @@
      */
     public function setAll($args = [], $reassign = false)
     {
-        $this->type         = isset($args[0]) && ($this->type === '' || $reassign)          ? $args[0] : $this->type;
-        $this->pid          = isset($args[1]) && ($this->pid === '' || $reassign)           ? $args[1] : $this->pid;
-        $this->destination  = isset($args[2]) && ($this->destination === '' || $reassign)   ? $args[2] : $this->destination;
-        $this->origin       = isset($args[3]) && ($this->origin === '' || $reassign)        ? $args[3] : $this->origin;
-        $this->message      = isset($args[4]) && ($this->message === '' || $reassign)       ? $args[4] : $this->message;
-        $this->exception    = isset($args[5]) && ($this->exception === '' || $reassign)     ? $args[5] : $this->exception;
-        $this->timestamp    = isset($args[6]) && ($this->timestamp == 0 || $reassign)       ? $args[6] : $this->timestamp;
+        $this->type         = isset($args[0]) && ($this->type === '' || $reassign) ? $args[0] : $this->type;
+        $this->pid          = isset($args[1]) && ($this->pid === '' || $reassign) ? $args[1] : $this->pid;
+        $this->destination  = isset($args[2]) && ($this->destination === '' || $reassign) ? $args[2] : $this->destination;
+        $this->origin       = isset($args[3]) && ($this->origin === '' || $reassign) ? $args[3] : $this->origin;
+        $this->message      = isset($args[4]) && ($this->message === '' || $reassign) ? $args[4] : $this->message;
+        $this->exception    = isset($args[5]) && ($this->exception === '' || $reassign) ? $args[5] : $this->exception;
+        $this->timestamp    = isset($args[6]) && ($this->timestamp == 0 || $reassign) ? $args[6] : $this->timestamp;
 
         return $this;
     }

src/Channel/Router/RouterRule.php

Spacing +1 added lines, -1 removed lines

@@ -143,6 +143,6 @@
      */
     public function setPointer($stack, $pointer)
     {
-        $this->pointer = [ $stack, $pointer ];
+        $this->pointer = [$stack, $pointer];
     }
 }

src/Channel/ChannelFactoryInterface.php

Braces +2 added lines, -1 removed lines

@@ -5,4 +5,5 @@
 use Dazzle\Util\Factory\FactoryInterface;
 
 interface ChannelFactoryInterface extends FactoryInterface
-{}
+{
+}

src/Channel/Record/RequestRecord.php

Spacing +1 added lines, -1 removed lines

@@ -45,7 +45,7 @@
         $this->pid     = $pid;
         $this->success = ($success !== null) ? $success : function() {};
         $this->failure = ($failure !== null) ? $failure : function() {};
-        $this->cancel  = ($cancel !== null)  ? $cancel  : function() {};
+        $this->cancel  = ($cancel !== null) ? $cancel : function() {};
         $this->timeout = $timeout;
     }
 

src/Channel/ChannelFactory.php

Spacing +1 added lines, -1 removed lines

@@ -37,7 +37,7 @@
             ->define(Channel::class, function($model, $config = []) use($factory, $modelFactory) {
                 return new Channel(
                     isset($config['name']) ? $config['name'] : $factory->getParam('name'),
-                    $modelFactory->create($model, [ $config ]),
+                    $modelFactory->create($model, [$config]),
                     $factory->getParam('router'),
                     $factory->getParam('encoder'),
                     isset($config['loop']) ? $config['loop'] : $factory->getParam('loop')

src/Channel/Model/ModelFactory.php

Upper-Lower-Casing +1 added lines, -1 removed lines

@@ -2,7 +2,7 @@
 
 namespace Dazzle\Channel\Model;
 
-use Dazzle\Channel\Model\Null\NullModel;
+use Dazzle\Channel\Model\null\NullModel;
 use Dazzle\Loop\LoopInterface;
 use Dazzle\Util\Factory\Factory;
 

src/Channel/Model/Null/NullModel.php

Upper-Lower-Casing +1 added lines, -1 removed lines

@@ -1,6 +1,6 @@
 <?php
 
-namespace Dazzle\Channel\Model\Null;
+namespace Dazzle\Channel\Model\null;
 
 use Dazzle\Channel\Model\ModelInterface;
 use Dazzle\Event\BaseEventEmitter;