console-helpers / process-iterator

src/ProcessIterator/ProcessIterator.php

Spacing +20 added lines, -20 removed lines

@@ -103,11 +103,11 @@ 
 	 */
 	public function __construct(array $processes)
 	{
-		$filtered_processes = array_filter($processes, function ($process) {
+		$filtered_processes = array_filter($processes, function($process) {
 			return ($process instanceof Process) && !$process->isRunning();
 		});
 
-		if ( count($filtered_processes) !== count($processes) ) {
+		if (count($filtered_processes) !== count($processes)) {
 			throw new \InvalidArgumentException(sprintf(
 				'The $processes argument must be an array of non-running instances of "%s" class.',
 				'\Symfony\Component\Process\Process'
@@ -124,7 +124,7 @@ 
 	 */
 	public function runAll()
 	{
-		foreach ( $this as $process ) {
+		foreach ($this as $process) {
 			$process->wait();
 		}
 
@@ -144,13 +144,13 @@ 
 	 */
 	public function addProcess(Process $process, $key = null)
 	{
-		if ( $key === null ) {
+		if ($key === null) {
 			$this->processes[] = $process;
 			end($this->processes);
 			$this->waitingQueue[] = key($this->processes);
 		}
 		else {
-			if ( !isset($this->processes[$key]) ) {
+			if (!isset($this->processes[$key])) {
 				$this->processes[$key] = $process;
 				$this->waitingQueue[] = $key;
 			}
@@ -234,7 +234,7 @@ 
 	{
 		$this->key = null;
 
-		if ( !count($this->waitingQueue) ) {
+		if (!count($this->waitingQueue)) {
 			return;
 		}
 
@@ -245,33 +245,33 @@ 
 		$executed_index = null;
 
 		do {
-			foreach ( $this->runningQueue as $index => $process_key ) {
+			foreach ($this->runningQueue as $index => $process_key) {
 				$process = $this->processes[$process_key];
 
 				try {
 					$process->checkTimeout();
 
-					if ( $process->isTerminated() ) {
-						if ( $executed_index === null ) {
+					if ($process->isTerminated()) {
+						if ($executed_index === null) {
 							$executed_index = $index;
 						}
 
 						continue;
 					}
 				}
-				catch ( \Exception $exception ) {
+				catch (\Exception $exception) {
 					$this->setProcessException($process_key, $exception);
 					$executed_index = $index;
 					break;
 				}
 			}
 
-			if ( $executed_index === null ) {
+			if ($executed_index === null) {
 				// Check for a setUpdateInterval() timeout.
-				if ( $timeout !== null ) {
+				if ($timeout !== null) {
 					$elapsed = microtime(true) - $start;
 
-					if ( $elapsed > $timeout ) {
+					if ($elapsed > $timeout) {
 						$this->isTimeout = true;
 
 						return;
@@ -280,7 +280,7 @@ 
 
 				usleep(1000);
 			}
-		} while ( $executed_index === null );
+		} while ($executed_index === null);
 
 		$this->key = $this->waitingQueue[$executed_index];
 		unset($this->waitingQueue[$executed_index]);
@@ -319,7 +319,7 @@ 
 	 */
 	public function current()
 	{
-		if ( $this->isTimeout ) {
+		if ($this->isTimeout) {
 			return null;
 		}
 
@@ -333,7 +333,7 @@ 
 	 */
 	public function key()
 	{
-		if ( $this->isTimeout ) {
+		if ($this->isTimeout) {
 			// Returning "null" only works since PHP 5.5, so return empty string instead.
 			return '';
 		}
@@ -348,7 +348,7 @@ 
 	 */
 	public function valid()
 	{
-		if ( $this->isTimeout ) {
+		if ($this->isTimeout) {
 			return true;
 		}
 
@@ -364,7 +364,7 @@ 
 	{
 		$old_running_queue = $this->runningQueue;
 
-		if ( $this->limit ) {
+		if ($this->limit) {
 			$this->runningQueue = array_slice($this->waitingQueue, 0, $this->limit, true);
 		}
 		else {
@@ -372,8 +372,8 @@ 
 		}
 
 		// Start processes, that were just added to the running queue.
-		foreach ( $this->runningQueue as $index => $process_key ) {
-			if ( !isset($old_running_queue[$index]) ) {
+		foreach ($this->runningQueue as $index => $process_key) {
+			if (!isset($old_running_queue[$index])) {
 				$this->processes[$process_key]->start();
 			}
 		}