PyRowMan / pheanstalk

src/Socket/NativeSocket.php

Spacing +1 added lines, -2 removed lines

@@ -123,8 +123,7 @@
         do {
             libxml_clear_errors();
                 $data .= isset($length) ?
-                    $this->_wrapper()->fgets($this->_socket, $length) :
-                    $this->_wrapper()->fgets($this->_socket);
+                    $this->_wrapper()->fgets($this->_socket, $length) : $this->_wrapper()->fgets($this->_socket);
             simplexml_load_string($data);
             if (!empty(libxml_get_errors()) && microtime(true) - $timer > $timeout) {
                 $this->disconnect();

src/Command/TubeExistsCommand.php

Spacing +2 added lines, -2 removed lines

@@ -38,10 +38,10 @@
         $tubes = parent::parseResponse($responseLine, $responseData);
 
         $name = $this->name;
-        $matchingTubes = $tubes->filter(function (Tube $tube) use ($name) {
+        $matchingTubes = $tubes->filter(function(Tube $tube) use ($name) {
             return $tube->getName() === $name;
         });
 
-        return !$matchingTubes->isEmpty() ?  $matchingTubes->first() : false;
+        return !$matchingTubes->isEmpty() ? $matchingTubes->first() : false;
     }
 }

src/Command/WorkflowExistsCommand.php

Spacing +2 added lines, -2 removed lines

@@ -38,10 +38,10 @@
         $workflows = parent::parseResponse($responseLine, $responseData);
 
         $name = $this->name;
-        $matchingWorkflows = $workflows->filter(function (Workflow $workflow) use ($name) {
+        $matchingWorkflows = $workflows->filter(function(Workflow $workflow) use ($name) {
             return $workflow->getName() === $name;
         });
 
-        return !$matchingWorkflows->isEmpty() ?  $matchingWorkflows->first() : false;
+        return !$matchingWorkflows->isEmpty() ? $matchingWorkflows->first() : false;
     }
 }

src/Command/GetWorkflowInstancesCommand.php

Spacing +2 added lines, -3 removed lines

@@ -93,7 +93,7 @@ 
             return new ArrayCollection([]);
         }
 
-        $instances = $responseData['workflow'] ;
+        $instances = $responseData['workflow'];
         $instances = isset($instances['tags']) ? [$instances['@attributes']] : $instances;
         $workflowInstances = new ArrayCollection([]);
         foreach ($instances as $instance) {
@@ -112,8 +112,7 @@ 
             $workflowInstances[] = new WorkflowInstance($instance);
         }
         $collection['rows'] = (int) (isset($responseData['@attributes']['rows'])) ?
-            (int) $responseData['@attributes']['rows'] :
-            $workflowInstances->count();
+            (int) $responseData['@attributes']['rows'] : $workflowInstances->count();
         $collection['page'] = $this->page;
         $collection['workflow_instances'] = $workflowInstances;
         return new ArrayCollection($collection);

src/Pheanstalk.php

Spacing +1 added lines, -1 removed lines

@@ -258,7 +258,7 @@
         } catch (ServerDuplicateEntryException $e) {
             if ($force) {
                 $workflows = $this->_dispatch(new Command\ListWorkflowsCommand());
-                $workflowToDelete = $workflows->filter(function (Workflow $listedWorkflow) use ($workflow) {
+                $workflowToDelete = $workflows->filter(function(Workflow $listedWorkflow) use ($workflow) {
                     return $listedWorkflow->getName() === $workflow->getName()
                         && $listedWorkflow->getGroup() === $workflow->getGroup();
                 })->first();

src/Structure/Task.php

Spacing +1 added lines, -1 removed lines

@@ -205,7 +205,7 @@
         $dom = new \DOMDocument("1.0", "utf-8");
         $root = $dom->createElement("task");
         foreach ($reflection->getProperties() as $property) {
-            $value = $this->{'get' . ucfirst($property->getName())}();
+            $value = $this->{'get'.ucfirst($property->getName())}();
             $root->setAttribute($this->from_camel_case($property->getName()), $value);
         }
         $dom->appendChild($root);

src/Structure/WorkflowInstance.php

Spacing +2 added lines, -2 removed lines

@@ -73,7 +73,7 @@ 
             }
         }
         if (!is_null($this->getRunningTasks()) && !is_null($this->getQueuedTasks())
-                && $this->getRunningTasks() - $this->getQueuedTasks() > 0 ) {
+                && $this->getRunningTasks() - $this->getQueuedTasks() > 0) {
             $this->setStatus(self::STATUS_RUNNING);
         }
         if (!is_null($this->getQueuedTasks()) && $this->getQueuedTasks() > 0) {
@@ -368,7 +368,7 @@ 
      */
     public function setJobInstances(ArrayCollection $jobInstances): WorkflowInstance
     {
-        $this->jobInstances = $jobInstances->filter(function (JobInstance $jobInstance) {
+        $this->jobInstances = $jobInstances->filter(function(JobInstance $jobInstance) {
             return true;
         });
         return $this;

src/Structure/Workflow.php

Spacing +1 added lines, -1 removed lines

@@ -138,7 +138,7 @@
      */
     public function setJobs(ArrayCollection $jobs): Workflow
     {
-        $this->jobs = $jobs->filter(function (Job $job) {
+        $this->jobs = $jobs->filter(function(Job $job) {
             return true;
         });
         return $this;

src/Structure/Job.php

Spacing +1 added lines, -1 removed lines

@@ -35,7 +35,7 @@
      */
     public function setTasks(ArrayCollection $tasks): Job
     {
-        $this->tasks = $tasks->filter(function (Task $task) {
+        $this->tasks = $tasks->filter(function(Task $task) {
             return true;
         });
         return $this;