mgdigital / BusQue

src/AutoQueue/AutoQueuingCommandBusAdapter.php

Spacing +4 added lines, -4 removed lines

@@ -8,7 +8,7 @@ 
 {
 
     private $baseCommandBus;
-    private $fromQueueCommands = [];
+    private $fromQueueCommands = [ ];
 
     public function __construct(CommandBusAdapterInterface $baseCommandBus)
     {
@@ -19,18 +19,18 @@ 
     {
         if ($fromQueue) {
             $hash = $this->getHash($command);
-            $this->fromQueueCommands[$hash] = true;
+            $this->fromQueueCommands[ $hash ] = true;
         }
         $this->baseCommandBus->handle($command, $fromQueue);
         if (isset($hash)) {
-            unset($this->fromQueueCommands[$hash]);
+            unset($this->fromQueueCommands[ $hash ]);
         }
     }
 
     public function shouldBeQueued($command): bool
     {
         $hash = $this->getHash($command);
-        return !isset($this->fromQueueCommands[$hash]);
+        return !isset($this->fromQueueCommands[ $hash ]);
     }
 
     private function getHash($command): string

src/AutoQueue/OrDecider.php

Spacing +2 added lines, -2 removed lines

@@ -8,12 +8,12 @@
     /**
      * @var DeciderInterface[]
      */
-    private $deciders = [];
+    private $deciders = [ ];
 
     public function __construct(array $deciders)
     {
         array_walk($deciders, function (DeciderInterface $decider) {
-            $this->deciders[] = $decider;
+            $this->deciders[ ] = $decider;
         });
     }
 

src/Predis/PredisAdapter.php

Spacing +1 added lines, -1 removed lines

@@ -131,7 +131,7 @@
         $this->client->pipeline(function (ClientContextInterface $client) use ($queueName) {
             self::cDeleteQueue($client, $queueName);
         });
-        $this->clearSchedule([$queueName]);
+        $this->clearSchedule([ $queueName ]);
     }
 
     public function purgeCommand(string $queueName, string $id)

src/Tactician/ChainedInflector.php

Spacing +3 added lines, -3 removed lines

@@ -10,7 +10,7 @@ 
     /**
      * @var MethodNameInflector[]
      */
-    private $inflectors = [];
+    private $inflectors = [ ];
 
     /**
      * @param MethodNameInflector[] $inflectors
@@ -18,7 +18,7 @@ 
     public function __construct(array $inflectors)
     {
         array_walk($inflectors, function (MethodNameInflector $inflector) {
-            $this->inflectors[] = $inflector;
+            $this->inflectors[ ] = $inflector;
         });
     }
 
@@ -26,7 +26,7 @@ 
     {
         foreach ($this->inflectors as $inflector) {
             $methodName = $inflector->inflect($command, $handler);
-            if (is_callable([$handler, $methodName])) {
+            if (is_callable([ $handler, $methodName ])) {
                 return $methodName;
             }
         }

src/AutoQueue/AndDecider.php

Spacing +2 added lines, -2 removed lines

@@ -8,12 +8,12 @@
     /**
      * @var DeciderInterface[]
      */
-    private $deciders = [];
+    private $deciders = [ ];
 
     public function __construct(array $deciders)
     {
         array_walk($deciders, function (DeciderInterface $decider) {
-            $this->deciders[] = $decider;
+            $this->deciders[ ] = $decider;
         });
     }