AlecRabbit\Spinner\Core\Output\ResourceStream

Complexity

Total Complexity

4

Size/Duplication

Total Lines	29
Duplicated Lines	0 %

Importance

Changes

0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	5	1
A	write()	0	10	3

<?php

declare(strict_types=1);

namespace AlecRabbit\Spinner\Core\Output;

use AlecRabbit\Spinner\Contract\Output\IResourceStream;
use AlecRabbit\Spinner\Exception\InvalidArgumentException;
use AlecRabbit\Spinner\Exception\RuntimeException;
use AlecRabbit\Spinner\Helper\Asserter;
use Traversable;

/**
 * @codeCoverageIgnore Not testable
 */
final class ResourceStream implements IResourceStream
{
    /**
     * @var resource
     */
    private $stream;

    /**
     * @param resource $stream
     *
     * @throws InvalidArgumentException
     */
    public function __construct(
        $stream
    ) {
        Asserter::assertStream($stream);
        $this->stream = $stream;
    }

    public function write(Traversable $data): void
    {
        /** @var string $item */
        foreach ($data as $item) {
            if (@fwrite($this->stream, $item) === false) {
                // should never happen
                throw new RuntimeException('Was unable to write to a stream.');
            }
        }
        fflush($this->stream);
    }
}