console-helpers / process-iterator

src/ProcessIterator/ProcessIterator.php

Spacing +22 added lines, -22 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();
 		}
 	}
@@ -142,13 +142,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;
 			}
@@ -232,7 +232,7 @@ 
 	{
 		$this->key = null;
 
-		if ( !count($this->waitingQueue) ) {
+		if (!count($this->waitingQueue)) {
 			return;
 		}
 
@@ -243,38 +243,38 @@ 
 		$executed_index = null;
 
 		do {
-			foreach ( $this->runningQueue as $index => $process_key ) {
+			foreach ($this->runningQueue as $index => $process_key) {
 				$process = $this->processes[$process_key];
 
 				try {
-					if ( $this->getProcessException($process_key) ) {
+					if ($this->getProcessException($process_key)) {
 						$executed_index = $index;
 						continue;
 					}
 
 					$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;
@@ -283,7 +283,7 @@ 
 
 				usleep(1000);
 			}
-		} while ( $executed_index === null );
+		} while ($executed_index === null);
 
 		$this->key = $this->waitingQueue[$executed_index];
 		unset($this->waitingQueue[$executed_index]);
@@ -312,7 +312,7 @@ 
 	 */
 	public function getProcessException($key = null)
 	{
-		if ( $key === null ) {
+		if ($key === null) {
 			$key = $this->key();
 		}
 
@@ -326,7 +326,7 @@ 
 	 */
 	public function current()
 	{
-		if ( $this->isTimeout ) {
+		if ($this->isTimeout) {
 			return null;
 		}
 
@@ -340,7 +340,7 @@ 
 	 */
 	public function key()
 	{
-		if ( $this->isTimeout ) {
+		if ($this->isTimeout) {
 			return null;
 		}
 
@@ -354,7 +354,7 @@ 
 	 */
 	public function valid()
 	{
-		if ( $this->isTimeout ) {
+		if ($this->isTimeout) {
 			return true;
 		}
 
@@ -370,7 +370,7 @@ 
 	{
 		$old_running_queue = $this->runningQueue;
 
-		if ( $this->limit ) {
+		if ($this->limit) {
 			$this->runningQueue = array_slice($this->waitingQueue, 0, $this->limit, true);
 		}
 		else {
@@ -378,8 +378,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();
 			}
 		}

Braces +4 added lines, -8 removed lines

@@ -146,13 +146,11 @@ 
 			$this->processes[] = $process;
 			end($this->processes);
 			$this->waitingQueue[] = key($this->processes);
-		}
-		else {
+		} else {
 			if ( !isset($this->processes[$key]) ) {
 				$this->processes[$key] = $process;
 				$this->waitingQueue[] = $key;
-			}
-			else {
+			} else {
 				throw new \InvalidArgumentException('The "' . $key . '" key is already in use.');
 			}
 		}
@@ -261,8 +259,7 @@ 
 
 						continue;
 					}
-				}
-				catch ( \Exception $exception ) {
+				} catch ( \Exception $exception ) {
 					$this->setProcessException($process_key, $exception);
 					$executed_index = $index;
 					break;
@@ -372,8 +369,7 @@ 
 
 		if ( $this->limit ) {
 			$this->runningQueue = array_slice($this->waitingQueue, 0, $this->limit, true);
-		}
-		else {
+		} else {
 			$this->runningQueue = $this->waitingQueue;
 		}