BEAR\Streamer\Streamer

Complexity

Total Complexity

7

Size/Duplication

Total Lines	64
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	0

Test Coverage

Coverage

100%

Importance

Changes

0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
A	addStreams()	0	4	1
A	getStream()	0	21	3
A	collect()	0	9	2

<?php
/**
 * This file is part of the BEAR.Streamer package.
 *
 * @license http://opensource.org/licenses/MIT MIT
 */
namespace BEAR\Streamer;

use BEAR\Streamer\Annotation\Stream;

final class Streamer implements StreamerInterface
{
    private $stream;

    /**
     * @var array
     */
    private $streams = [];

    /**
     * @Stream
     *
     * @param resource $stream
     */
    public function __construct($stream)
    {
        $this->stream = $stream;
    }

    /**
     * @param resource[] $streams
     */
    public function addStreams(array $streams)
    {
        $this->streams += $streams;
    }

    /**
     * Return single root stream
     *
     * @return resource
     */
    public function getStream(string $string)
    {
        $stream = $this->stream;
        rewind($stream);
        $hash = array_keys($this->streams);
        $regex = sprintf('/(%s)/', implode('|', $hash));
        preg_match_all($regex, $string, $match, PREG_SET_ORDER);
        $list = $this->collect($match);

It seems like $match can also be of type null; however, BEAR\Streamer\Streamer::collect() does only seem to accept array, maybe add an additional type check?

        $bodies = preg_split($regex, $string);
        foreach ($bodies as $body) {
            fwrite($stream, $body);
            $index = array_shift($list);
            if (isset($this->streams[$index])) {
                $popStream = $this->streams[$index];
                rewind($popStream);
                stream_copy_to_stream($popStream, $stream);
            }
        }

        return $stream;
    }

    private function collect(array $match) : array
    {
        $list = [];
        foreach ($match as $item) {
            $list[] = $item[0];
        }

        return $list;
    }
}