gravityview / GravityView

vendor/symfony/process/Exception/ProcessTimedOutException.php

Indentation +37 added lines, -37 removed lines

@@ -20,50 +20,50 @@
  */
 class ProcessTimedOutException extends RuntimeException
 {
-    public const TYPE_GENERAL = 1;
-    public const TYPE_IDLE = 2;
+	public const TYPE_GENERAL = 1;
+	public const TYPE_IDLE = 2;
 
-    private $process;
-    private $timeoutType;
+	private $process;
+	private $timeoutType;
 
-    public function __construct(Process $process, int $timeoutType)
-    {
-        $this->process = $process;
-        $this->timeoutType = $timeoutType;
+	public function __construct(Process $process, int $timeoutType)
+	{
+		$this->process = $process;
+		$this->timeoutType = $timeoutType;
 
-        parent::__construct(sprintf(
-            'The process "%s" exceeded the timeout of %s seconds.',
-            $process->getCommandLine(),
-            $this->getExceededTimeout()
-        ));
-    }
+		parent::__construct(sprintf(
+			'The process "%s" exceeded the timeout of %s seconds.',
+			$process->getCommandLine(),
+			$this->getExceededTimeout()
+		));
+	}
 
-    public function getProcess()
-    {
-        return $this->process;
-    }
+	public function getProcess()
+	{
+		return $this->process;
+	}
 
-    public function isGeneralTimeout()
-    {
-        return self::TYPE_GENERAL === $this->timeoutType;
-    }
+	public function isGeneralTimeout()
+	{
+		return self::TYPE_GENERAL === $this->timeoutType;
+	}
 
-    public function isIdleTimeout()
-    {
-        return self::TYPE_IDLE === $this->timeoutType;
-    }
+	public function isIdleTimeout()
+	{
+		return self::TYPE_IDLE === $this->timeoutType;
+	}
 
-    public function getExceededTimeout()
-    {
-        switch ($this->timeoutType) {
-            case self::TYPE_GENERAL:
-                return $this->process->getTimeout();
+	public function getExceededTimeout()
+	{
+		switch ($this->timeoutType) {
+			case self::TYPE_GENERAL:
+				return $this->process->getTimeout();
 
-            case self::TYPE_IDLE:
-                return $this->process->getIdleTimeout();
+			case self::TYPE_IDLE:
+				return $this->process->getIdleTimeout();
 
-            default:
-                throw new \LogicException(sprintf('Unknown timeout type "%d".', $this->timeoutType));
-        }
-    }
+			default:
+				throw new \LogicException(sprintf('Unknown timeout type "%d".', $this->timeoutType));
+		}
+	}
 }

Spacing +5 added lines, -5 removed lines

@@ -26,16 +26,16 @@ 
     private $process;
     private $timeoutType;
 
-    public function __construct(Process $process, int $timeoutType)
+    public function __construct( Process $process, int $timeoutType )
     {
         $this->process = $process;
         $this->timeoutType = $timeoutType;
 
-        parent::__construct(sprintf(
+        parent::__construct( sprintf(
             'The process "%s" exceeded the timeout of %s seconds.',
             $process->getCommandLine(),
             $this->getExceededTimeout()
-        ));
+        ) );
     }
 
     public function getProcess()
@@ -55,7 +55,7 @@ 
 
     public function getExceededTimeout()
     {
-        switch ($this->timeoutType) {
+        switch ( $this->timeoutType ) {
             case self::TYPE_GENERAL:
                 return $this->process->getTimeout();
 
@@ -63,7 +63,7 @@ 
                 return $this->process->getIdleTimeout();
 
             default:
-                throw new \LogicException(sprintf('Unknown timeout type "%d".', $this->timeoutType));
+                throw new \LogicException( sprintf( 'Unknown timeout type "%d".', $this->timeoutType ) );
         }
     }
 }

Braces +6 added lines, -12 removed lines

@@ -18,16 +18,14 @@ 
  *
  * @author Johannes M. Schmitt <schmittjoh@gmail.com>
  */
-class ProcessTimedOutException extends RuntimeException
-{
+class ProcessTimedOutException extends RuntimeException {
     public const TYPE_GENERAL = 1;
     public const TYPE_IDLE = 2;
 
     private $process;
     private $timeoutType;
 
-    public function __construct(Process $process, int $timeoutType)
-    {
+    public function __construct(Process $process, int $timeoutType) {
         $this->process = $process;
         $this->timeoutType = $timeoutType;
 
@@ -38,23 +36,19 @@ 
         ));
     }
 
-    public function getProcess()
-    {
+    public function getProcess() {
         return $this->process;
     }
 
-    public function isGeneralTimeout()
-    {
+    public function isGeneralTimeout() {
         return self::TYPE_GENERAL === $this->timeoutType;
     }
 
-    public function isIdleTimeout()
-    {
+    public function isIdleTimeout() {
         return self::TYPE_IDLE === $this->timeoutType;
     }
 
-    public function getExceededTimeout()
-    {
+    public function getExceededTimeout() {
         switch ($this->timeoutType) {
             case self::TYPE_GENERAL:
                 return $this->process->getTimeout();

vendor/symfony/process/Exception/InvalidArgumentException.php

Braces +1 added lines, -2 removed lines

@@ -16,6 +16,5 @@
  *
  * @author Romain Neutron <imprec@gmail.com>
  */
-class InvalidArgumentException extends \InvalidArgumentException implements ExceptionInterface
-{
+class InvalidArgumentException extends \InvalidArgumentException implements ExceptionInterface {
 }

vendor/symfony/process/Exception/ExceptionInterface.php

Braces +1 added lines, -2 removed lines

@@ -16,6 +16,5 @@
  *
  * @author Johannes M. Schmitt <schmittjoh@gmail.com>
  */
-interface ExceptionInterface extends \Throwable
-{
+interface ExceptionInterface extends \Throwable {
 }

vendor/symfony/process/Exception/ProcessFailedException.php

Indentation +31 added lines, -31 removed lines

@@ -20,35 +20,35 @@
  */
 class ProcessFailedException extends RuntimeException
 {
-    private $process;
-
-    public function __construct(Process $process)
-    {
-        if ($process->isSuccessful()) {
-            throw new InvalidArgumentException('Expected a failed process, but the given process was successful.');
-        }
-
-        $error = sprintf('The command "%s" failed.'."\n\nExit Code: %s(%s)\n\nWorking directory: %s",
-            $process->getCommandLine(),
-            $process->getExitCode(),
-            $process->getExitCodeText(),
-            $process->getWorkingDirectory()
-        );
-
-        if (!$process->isOutputDisabled()) {
-            $error .= sprintf("\n\nOutput:\n================\n%s\n\nError Output:\n================\n%s",
-                $process->getOutput(),
-                $process->getErrorOutput()
-            );
-        }
-
-        parent::__construct($error);
-
-        $this->process = $process;
-    }
-
-    public function getProcess()
-    {
-        return $this->process;
-    }
+	private $process;
+
+	public function __construct(Process $process)
+	{
+		if ($process->isSuccessful()) {
+			throw new InvalidArgumentException('Expected a failed process, but the given process was successful.');
+		}
+
+		$error = sprintf('The command "%s" failed.'."\n\nExit Code: %s(%s)\n\nWorking directory: %s",
+			$process->getCommandLine(),
+			$process->getExitCode(),
+			$process->getExitCodeText(),
+			$process->getWorkingDirectory()
+		);
+
+		if (!$process->isOutputDisabled()) {
+			$error .= sprintf("\n\nOutput:\n================\n%s\n\nError Output:\n================\n%s",
+				$process->getOutput(),
+				$process->getErrorOutput()
+			);
+		}
+
+		parent::__construct($error);
+
+		$this->process = $process;
+	}
+
+	public function getProcess()
+	{
+		return $this->process;
+	}
 }

Spacing +7 added lines, -7 removed lines

@@ -22,27 +22,27 @@
 {
     private $process;
 
-    public function __construct(Process $process)
+    public function __construct( Process $process )
     {
-        if ($process->isSuccessful()) {
-            throw new InvalidArgumentException('Expected a failed process, but the given process was successful.');
+        if ( $process->isSuccessful() ) {
+            throw new InvalidArgumentException( 'Expected a failed process, but the given process was successful.' );
         }
 
-        $error = sprintf('The command "%s" failed.'."\n\nExit Code: %s(%s)\n\nWorking directory: %s",
+        $error = sprintf( 'The command "%s" failed.' . "\n\nExit Code: %s(%s)\n\nWorking directory: %s",
             $process->getCommandLine(),
             $process->getExitCode(),
             $process->getExitCodeText(),
             $process->getWorkingDirectory()
         );
 
-        if (!$process->isOutputDisabled()) {
-            $error .= sprintf("\n\nOutput:\n================\n%s\n\nError Output:\n================\n%s",
+        if ( ! $process->isOutputDisabled() ) {
+            $error .= sprintf( "\n\nOutput:\n================\n%s\n\nError Output:\n================\n%s",
                 $process->getOutput(),
                 $process->getErrorOutput()
             );
         }
 
-        parent::__construct($error);
+        parent::__construct( $error );
 
         $this->process = $process;
     }

Braces +3 added lines, -6 removed lines

@@ -18,12 +18,10 @@ 
  *
  * @author Johannes M. Schmitt <schmittjoh@gmail.com>
  */
-class ProcessFailedException extends RuntimeException
-{
+class ProcessFailedException extends RuntimeException {
     private $process;
 
-    public function __construct(Process $process)
-    {
+    public function __construct(Process $process) {
         if ($process->isSuccessful()) {
             throw new InvalidArgumentException('Expected a failed process, but the given process was successful.');
         }
@@ -47,8 +45,7 @@ 
         $this->process = $process;
     }
 
-    public function getProcess()
-    {
+    public function getProcess() {
         return $this->process;
     }
 }

vendor/symfony/process/Exception/RuntimeException.php

Braces +1 added lines, -2 removed lines

@@ -16,6 +16,5 @@
  *
  * @author Johannes M. Schmitt <schmittjoh@gmail.com>
  */
-class RuntimeException extends \RuntimeException implements ExceptionInterface
-{
+class RuntimeException extends \RuntimeException implements ExceptionInterface {
 }

vendor/symfony/process/Exception/ProcessSignaledException.php

Indentation +14 added lines, -14 removed lines

@@ -20,22 +20,22 @@
  */
 final class ProcessSignaledException extends RuntimeException
 {
-    private $process;
+	private $process;
 
-    public function __construct(Process $process)
-    {
-        $this->process = $process;
+	public function __construct(Process $process)
+	{
+		$this->process = $process;
 
-        parent::__construct(sprintf('The process has been signaled with signal "%s".', $process->getTermSignal()));
-    }
+		parent::__construct(sprintf('The process has been signaled with signal "%s".', $process->getTermSignal()));
+	}
 
-    public function getProcess(): Process
-    {
-        return $this->process;
-    }
+	public function getProcess(): Process
+	{
+		return $this->process;
+	}
 
-    public function getSignal(): int
-    {
-        return $this->getProcess()->getTermSignal();
-    }
+	public function getSignal(): int
+	{
+		return $this->getProcess()->getTermSignal();
+	}
 }

Spacing +2 added lines, -2 removed lines

@@ -22,11 +22,11 @@
 {
     private $process;
 
-    public function __construct(Process $process)
+    public function __construct( Process $process )
     {
         $this->process = $process;
 
-        parent::__construct(sprintf('The process has been signaled with signal "%s".', $process->getTermSignal()));
+        parent::__construct( sprintf( 'The process has been signaled with signal "%s".', $process->getTermSignal() ) );
     }
 
     public function getProcess(): Process

Braces +2 added lines, -4 removed lines

@@ -18,12 +18,10 @@
  *
  * @author Sullivan Senechal <soullivaneuh@gmail.com>
  */
-final class ProcessSignaledException extends RuntimeException
-{
+final class ProcessSignaledException extends RuntimeException {
     private $process;
 
-    public function __construct(Process $process)
-    {
+    public function __construct(Process $process) {
         $this->process = $process;
 
         parent::__construct(sprintf('The process has been signaled with signal "%s".', $process->getTermSignal()));

vendor/symfony/process/Exception/LogicException.php

Braces +1 added lines, -2 removed lines

@@ -16,6 +16,5 @@
  *
  * @author Romain Neutron <imprec@gmail.com>
  */
-class LogicException extends \LogicException implements ExceptionInterface
-{
+class LogicException extends \LogicException implements ExceptionInterface {
 }

vendor/symfony/process/Pipes/PipesInterface.php

Indentation +38 added lines, -38 removed lines

@@ -20,42 +20,42 @@
  */
 interface PipesInterface
 {
-    public const CHUNK_SIZE = 16384;
-
-    /**
-     * Returns an array of descriptors for the use of proc_open.
-     */
-    public function getDescriptors(): array;
-
-    /**
-     * Returns an array of filenames indexed by their related stream in case these pipes use temporary files.
-     *
-     * @return string[]
-     */
-    public function getFiles(): array;
-
-    /**
-     * Reads data in file handles and pipes.
-     *
-     * @param bool $blocking Whether to use blocking calls or not
-     * @param bool $close    Whether to close pipes if they've reached EOF
-     *
-     * @return string[] An array of read data indexed by their fd
-     */
-    public function readAndWrite(bool $blocking, bool $close = false): array;
-
-    /**
-     * Returns if the current state has open file handles or pipes.
-     */
-    public function areOpen(): bool;
-
-    /**
-     * Returns if pipes are able to read output.
-     */
-    public function haveReadSupport(): bool;
-
-    /**
-     * Closes file handles and pipes.
-     */
-    public function close();
+	public const CHUNK_SIZE = 16384;
+
+	/**
+	 * Returns an array of descriptors for the use of proc_open.
+	 */
+	public function getDescriptors(): array;
+
+	/**
+	 * Returns an array of filenames indexed by their related stream in case these pipes use temporary files.
+	 *
+	 * @return string[]
+	 */
+	public function getFiles(): array;
+
+	/**
+	 * Reads data in file handles and pipes.
+	 *
+	 * @param bool $blocking Whether to use blocking calls or not
+	 * @param bool $close    Whether to close pipes if they've reached EOF
+	 *
+	 * @return string[] An array of read data indexed by their fd
+	 */
+	public function readAndWrite(bool $blocking, bool $close = false): array;
+
+	/**
+	 * Returns if the current state has open file handles or pipes.
+	 */
+	public function areOpen(): bool;
+
+	/**
+	 * Returns if pipes are able to read output.
+	 */
+	public function haveReadSupport(): bool;
+
+	/**
+	 * Closes file handles and pipes.
+	 */
+	public function close();
 }

Spacing +1 added lines, -1 removed lines

@@ -42,7 +42,7 @@
      *
      * @return string[] An array of read data indexed by their fd
      */
-    public function readAndWrite(bool $blocking, bool $close = false): array;
+    public function readAndWrite( bool $blocking, bool $close = false ): array;
 
     /**
      * Returns if the current state has open file handles or pipes.

Braces +1 added lines, -2 removed lines

@@ -18,8 +18,7 @@
  *
  * @internal
  */
-interface PipesInterface
-{
+interface PipesInterface {
     public const CHUNK_SIZE = 16384;
 
     /**

vendor/symfony/process/Pipes/AbstractPipes.php

Braces +5 added lines, -10 removed lines

@@ -18,8 +18,7 @@ 
  *
  * @internal
  */
-abstract class AbstractPipes implements PipesInterface
-{
+abstract class AbstractPipes implements PipesInterface {
     public $pipes = [];
 
     private $inputBuffer = '';
@@ -30,8 +29,7 @@ 
     /**
      * @param resource|string|int|float|bool|\Iterator|null $input
      */
-    public function __construct($input)
-    {
+    public function __construct($input) {
         if (\is_resource($input) || $input instanceof \Iterator) {
             $this->input = $input;
         } elseif (\is_string($input)) {
@@ -44,8 +42,7 @@ 
     /**
      * {@inheritdoc}
      */
-    public function close()
-    {
+    public function close() {
         foreach ($this->pipes as $pipe) {
             fclose($pipe);
         }
@@ -67,8 +64,7 @@ 
     /**
      * Unblocks streams.
      */
-    protected function unblock()
-    {
+    protected function unblock() {
         if (!$this->blocked) {
             return;
         }
@@ -171,8 +167,7 @@ 
     /**
      * @internal
      */
-    public function handleError(int $type, string $msg)
-    {
+    public function handleError(int $type, string $msg) {
         $this->lastError = $msg;
     }
 }

Indentation +155 added lines, -155 removed lines

@@ -20,159 +20,159 @@
  */
 abstract class AbstractPipes implements PipesInterface
 {
-    public $pipes = [];
-
-    private $inputBuffer = '';
-    private $input;
-    private $blocked = true;
-    private $lastError;
-
-    /**
-     * @param resource|string|int|float|bool|\Iterator|null $input
-     */
-    public function __construct($input)
-    {
-        if (\is_resource($input) || $input instanceof \Iterator) {
-            $this->input = $input;
-        } elseif (\is_string($input)) {
-            $this->inputBuffer = $input;
-        } else {
-            $this->inputBuffer = (string) $input;
-        }
-    }
-
-    /**
-     * {@inheritdoc}
-     */
-    public function close()
-    {
-        foreach ($this->pipes as $pipe) {
-            fclose($pipe);
-        }
-        $this->pipes = [];
-    }
-
-    /**
-     * Returns true if a system call has been interrupted.
-     */
-    protected function hasSystemCallBeenInterrupted(): bool
-    {
-        $lastError = $this->lastError;
-        $this->lastError = null;
-
-        // stream_select returns false when the `select` system call is interrupted by an incoming signal
-        return null !== $lastError && false !== stripos($lastError, 'interrupted system call');
-    }
-
-    /**
-     * Unblocks streams.
-     */
-    protected function unblock()
-    {
-        if (!$this->blocked) {
-            return;
-        }
-
-        foreach ($this->pipes as $pipe) {
-            stream_set_blocking($pipe, 0);
-        }
-        if (\is_resource($this->input)) {
-            stream_set_blocking($this->input, 0);
-        }
-
-        $this->blocked = false;
-    }
-
-    /**
-     * Writes input to stdin.
-     *
-     * @throws InvalidArgumentException When an input iterator yields a non supported value
-     */
-    protected function write(): ?array
-    {
-        if (!isset($this->pipes[0])) {
-            return null;
-        }
-        $input = $this->input;
-
-        if ($input instanceof \Iterator) {
-            if (!$input->valid()) {
-                $input = null;
-            } elseif (\is_resource($input = $input->current())) {
-                stream_set_blocking($input, 0);
-            } elseif (!isset($this->inputBuffer[0])) {
-                if (!\is_string($input)) {
-                    if (!is_scalar($input)) {
-                        throw new InvalidArgumentException(sprintf('"%s" yielded a value of type "%s", but only scalars and stream resources are supported.', \get_class($this->input), \gettype($input)));
-                    }
-                    $input = (string) $input;
-                }
-                $this->inputBuffer = $input;
-                $this->input->next();
-                $input = null;
-            } else {
-                $input = null;
-            }
-        }
-
-        $r = $e = [];
-        $w = [$this->pipes[0]];
-
-        // let's have a look if something changed in streams
-        if (false === @stream_select($r, $w, $e, 0, 0)) {
-            return null;
-        }
-
-        foreach ($w as $stdin) {
-            if (isset($this->inputBuffer[0])) {
-                $written = fwrite($stdin, $this->inputBuffer);
-                $this->inputBuffer = substr($this->inputBuffer, $written);
-                if (isset($this->inputBuffer[0])) {
-                    return [$this->pipes[0]];
-                }
-            }
-
-            if ($input) {
-                for (;;) {
-                    $data = fread($input, self::CHUNK_SIZE);
-                    if (!isset($data[0])) {
-                        break;
-                    }
-                    $written = fwrite($stdin, $data);
-                    $data = substr($data, $written);
-                    if (isset($data[0])) {
-                        $this->inputBuffer = $data;
-
-                        return [$this->pipes[0]];
-                    }
-                }
-                if (feof($input)) {
-                    if ($this->input instanceof \Iterator) {
-                        $this->input->next();
-                    } else {
-                        $this->input = null;
-                    }
-                }
-            }
-        }
-
-        // no input to read on resource, buffer is empty
-        if (!isset($this->inputBuffer[0]) && !($this->input instanceof \Iterator ? $this->input->valid() : $this->input)) {
-            $this->input = null;
-            fclose($this->pipes[0]);
-            unset($this->pipes[0]);
-        } elseif (!$w) {
-            return [$this->pipes[0]];
-        }
-
-        return null;
-    }
-
-    /**
-     * @internal
-     */
-    public function handleError(int $type, string $msg)
-    {
-        $this->lastError = $msg;
-    }
+	public $pipes = [];
+
+	private $inputBuffer = '';
+	private $input;
+	private $blocked = true;
+	private $lastError;
+
+	/**
+	 * @param resource|string|int|float|bool|\Iterator|null $input
+	 */
+	public function __construct($input)
+	{
+		if (\is_resource($input) || $input instanceof \Iterator) {
+			$this->input = $input;
+		} elseif (\is_string($input)) {
+			$this->inputBuffer = $input;
+		} else {
+			$this->inputBuffer = (string) $input;
+		}
+	}
+
+	/**
+	 * {@inheritdoc}
+	 */
+	public function close()
+	{
+		foreach ($this->pipes as $pipe) {
+			fclose($pipe);
+		}
+		$this->pipes = [];
+	}
+
+	/**
+	 * Returns true if a system call has been interrupted.
+	 */
+	protected function hasSystemCallBeenInterrupted(): bool
+	{
+		$lastError = $this->lastError;
+		$this->lastError = null;
+
+		// stream_select returns false when the `select` system call is interrupted by an incoming signal
+		return null !== $lastError && false !== stripos($lastError, 'interrupted system call');
+	}
+
+	/**
+	 * Unblocks streams.
+	 */
+	protected function unblock()
+	{
+		if (!$this->blocked) {
+			return;
+		}
+
+		foreach ($this->pipes as $pipe) {
+			stream_set_blocking($pipe, 0);
+		}
+		if (\is_resource($this->input)) {
+			stream_set_blocking($this->input, 0);
+		}
+
+		$this->blocked = false;
+	}
+
+	/**
+	 * Writes input to stdin.
+	 *
+	 * @throws InvalidArgumentException When an input iterator yields a non supported value
+	 */
+	protected function write(): ?array
+	{
+		if (!isset($this->pipes[0])) {
+			return null;
+		}
+		$input = $this->input;
+
+		if ($input instanceof \Iterator) {
+			if (!$input->valid()) {
+				$input = null;
+			} elseif (\is_resource($input = $input->current())) {
+				stream_set_blocking($input, 0);
+			} elseif (!isset($this->inputBuffer[0])) {
+				if (!\is_string($input)) {
+					if (!is_scalar($input)) {
+						throw new InvalidArgumentException(sprintf('"%s" yielded a value of type "%s", but only scalars and stream resources are supported.', \get_class($this->input), \gettype($input)));
+					}
+					$input = (string) $input;
+				}
+				$this->inputBuffer = $input;
+				$this->input->next();
+				$input = null;
+			} else {
+				$input = null;
+			}
+		}
+
+		$r = $e = [];
+		$w = [$this->pipes[0]];
+
+		// let's have a look if something changed in streams
+		if (false === @stream_select($r, $w, $e, 0, 0)) {
+			return null;
+		}
+
+		foreach ($w as $stdin) {
+			if (isset($this->inputBuffer[0])) {
+				$written = fwrite($stdin, $this->inputBuffer);
+				$this->inputBuffer = substr($this->inputBuffer, $written);
+				if (isset($this->inputBuffer[0])) {
+					return [$this->pipes[0]];
+				}
+			}
+
+			if ($input) {
+				for (;;) {
+					$data = fread($input, self::CHUNK_SIZE);
+					if (!isset($data[0])) {
+						break;
+					}
+					$written = fwrite($stdin, $data);
+					$data = substr($data, $written);
+					if (isset($data[0])) {
+						$this->inputBuffer = $data;
+
+						return [$this->pipes[0]];
+					}
+				}
+				if (feof($input)) {
+					if ($this->input instanceof \Iterator) {
+						$this->input->next();
+					} else {
+						$this->input = null;
+					}
+				}
+			}
+		}
+
+		// no input to read on resource, buffer is empty
+		if (!isset($this->inputBuffer[0]) && !($this->input instanceof \Iterator ? $this->input->valid() : $this->input)) {
+			$this->input = null;
+			fclose($this->pipes[0]);
+			unset($this->pipes[0]);
+		} elseif (!$w) {
+			return [$this->pipes[0]];
+		}
+
+		return null;
+	}
+
+	/**
+	 * @internal
+	 */
+	public function handleError(int $type, string $msg)
+	{
+		$this->lastError = $msg;
+	}
 }

Spacing +49 added lines, -49 removed lines

@@ -20,7 +20,7 @@ 
  */
 abstract class AbstractPipes implements PipesInterface
 {
-    public $pipes = [];
+    public $pipes = [ ];
 
     private $inputBuffer = '';
     private $input;
@@ -30,14 +30,14 @@ 
     /**
      * @param resource|string|int|float|bool|\Iterator|null $input
      */
-    public function __construct($input)
+    public function __construct( $input )
     {
-        if (\is_resource($input) || $input instanceof \Iterator) {
+        if ( \is_resource( $input ) || $input instanceof \Iterator ) {
             $this->input = $input;
-        } elseif (\is_string($input)) {
+        } elseif ( \is_string( $input ) ) {
             $this->inputBuffer = $input;
         } else {
-            $this->inputBuffer = (string) $input;
+            $this->inputBuffer = (string)$input;
         }
     }
 
@@ -46,10 +46,10 @@ 
      */
     public function close()
     {
-        foreach ($this->pipes as $pipe) {
-            fclose($pipe);
+        foreach ( $this->pipes as $pipe ) {
+            fclose( $pipe );
         }
-        $this->pipes = [];
+        $this->pipes = [ ];
     }
 
     /**
@@ -61,7 +61,7 @@ 
         $this->lastError = null;
 
         // stream_select returns false when the `select` system call is interrupted by an incoming signal
-        return null !== $lastError && false !== stripos($lastError, 'interrupted system call');
+        return null !== $lastError && false !== stripos( $lastError, 'interrupted system call' );
     }
 
     /**
@@ -69,15 +69,15 @@ 
      */
     protected function unblock()
     {
-        if (!$this->blocked) {
+        if ( ! $this->blocked ) {
             return;
         }
 
-        foreach ($this->pipes as $pipe) {
-            stream_set_blocking($pipe, 0);
+        foreach ( $this->pipes as $pipe ) {
+            stream_set_blocking( $pipe, 0 );
         }
-        if (\is_resource($this->input)) {
-            stream_set_blocking($this->input, 0);
+        if ( \is_resource( $this->input ) ) {
+            stream_set_blocking( $this->input, 0 );
         }
 
         $this->blocked = false;
@@ -90,22 +90,22 @@ 
      */
     protected function write(): ?array
     {
-        if (!isset($this->pipes[0])) {
+        if ( ! isset( $this->pipes[ 0 ] ) ) {
             return null;
         }
         $input = $this->input;
 
-        if ($input instanceof \Iterator) {
-            if (!$input->valid()) {
+        if ( $input instanceof \Iterator ) {
+            if ( ! $input->valid() ) {
                 $input = null;
-            } elseif (\is_resource($input = $input->current())) {
-                stream_set_blocking($input, 0);
-            } elseif (!isset($this->inputBuffer[0])) {
-                if (!\is_string($input)) {
-                    if (!is_scalar($input)) {
-                        throw new InvalidArgumentException(sprintf('"%s" yielded a value of type "%s", but only scalars and stream resources are supported.', \get_class($this->input), \gettype($input)));
+            } elseif ( \is_resource( $input = $input->current() ) ) {
+                stream_set_blocking( $input, 0 );
+            } elseif ( ! isset( $this->inputBuffer[ 0 ] ) ) {
+                if ( ! \is_string( $input ) ) {
+                    if ( ! is_scalar( $input ) ) {
+                        throw new InvalidArgumentException( sprintf( '"%s" yielded a value of type "%s", but only scalars and stream resources are supported.', \get_class( $this->input ), \gettype( $input ) ) );
                     }
-                    $input = (string) $input;
+                    $input = (string)$input;
                 }
                 $this->inputBuffer = $input;
                 $this->input->next();
@@ -115,39 +115,39 @@ 
             }
         }
 
-        $r = $e = [];
-        $w = [$this->pipes[0]];
+        $r = $e = [ ];
+        $w = [ $this->pipes[ 0 ] ];
 
         // let's have a look if something changed in streams
-        if (false === @stream_select($r, $w, $e, 0, 0)) {
+        if ( false === @stream_select( $r, $w, $e, 0, 0 ) ) {
             return null;
         }
 
-        foreach ($w as $stdin) {
-            if (isset($this->inputBuffer[0])) {
-                $written = fwrite($stdin, $this->inputBuffer);
-                $this->inputBuffer = substr($this->inputBuffer, $written);
-                if (isset($this->inputBuffer[0])) {
-                    return [$this->pipes[0]];
+        foreach ( $w as $stdin ) {
+            if ( isset( $this->inputBuffer[ 0 ] ) ) {
+                $written = fwrite( $stdin, $this->inputBuffer );
+                $this->inputBuffer = substr( $this->inputBuffer, $written );
+                if ( isset( $this->inputBuffer[ 0 ] ) ) {
+                    return [ $this->pipes[ 0 ] ];
                 }
             }
 
-            if ($input) {
-                for (;;) {
-                    $data = fread($input, self::CHUNK_SIZE);
-                    if (!isset($data[0])) {
+            if ( $input ) {
+                for ( ;; ) {
+                    $data = fread( $input, self::CHUNK_SIZE );
+                    if ( ! isset( $data[ 0 ] ) ) {
                         break;
                     }
-                    $written = fwrite($stdin, $data);
-                    $data = substr($data, $written);
-                    if (isset($data[0])) {
+                    $written = fwrite( $stdin, $data );
+                    $data = substr( $data, $written );
+                    if ( isset( $data[ 0 ] ) ) {
                         $this->inputBuffer = $data;
 
-                        return [$this->pipes[0]];
+                        return [ $this->pipes[ 0 ] ];
                     }
                 }
-                if (feof($input)) {
-                    if ($this->input instanceof \Iterator) {
+                if ( feof( $input ) ) {
+                    if ( $this->input instanceof \Iterator ) {
                         $this->input->next();
                     } else {
                         $this->input = null;
@@ -157,12 +157,12 @@ 
         }
 
         // no input to read on resource, buffer is empty
-        if (!isset($this->inputBuffer[0]) && !($this->input instanceof \Iterator ? $this->input->valid() : $this->input)) {
+        if ( ! isset( $this->inputBuffer[ 0 ] ) && ! ( $this->input instanceof \Iterator ? $this->input->valid() : $this->input ) ) {
             $this->input = null;
-            fclose($this->pipes[0]);
-            unset($this->pipes[0]);
-        } elseif (!$w) {
-            return [$this->pipes[0]];
+            fclose( $this->pipes[ 0 ] );
+            unset( $this->pipes[ 0 ] );
+        } elseif ( ! $w ) {
+            return [ $this->pipes[ 0 ] ];
         }
 
         return null;
@@ -171,7 +171,7 @@ 
     /**
      * @internal
      */
-    public function handleError(int $type, string $msg)
+    public function handleError( int $type, string $msg )
     {
         $this->lastError = $msg;
     }