CMProductions / queues

src/Cmp/Queues/Domain/Task/Producer.php

Spacing +1 added lines, -1 removed lines

@@ -40,7 +40,7 @@
      */
     public function produce()
     {
-        if(!isset($this->tasks[0])) {
+        if (!isset($this->tasks[0])) {
             throw new TaskException('You must add at least 1 Task before producing.');
         }
         $this->queueWriter->write($this->tasks);

src/Cmp/Queues/Domain/Task/Consumer.php

Spacing +3 added lines, -3 removed lines

@@ -20,12 +20,12 @@
         $this->queueReader = $queueReader;
     }
 
-    public function consume(callable $callback, $timeout=0)
+    public function consume(callable $callback, $timeout = 0)
     {
-        while(true) {
+        while (true) {
             try {
                 $this->consumeOnce($callback, $timeout);
-            } catch(TimeoutReaderException $e) {
+            } catch (TimeoutReaderException $e) {
                 break;
             }
         }