Docker\Stream\CallbackStream

Complexity

Total Complexity

8

Size/Duplication

Total Lines	54
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	1

Test Coverage

Coverage

82.61%

Importance

Changes	3
Bugs	0	Features	3

5 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
A	onFrame()	0	4	1
B	wait()	0	16	5
A	closeAndRead()	0	5	1
	readFrame()	0	1	?

<?php

namespace Docker\Stream;

use Psr\Http\Message\StreamInterface;

abstract class CallbackStream
{
    protected $stream;

    private $onNewFrameCallables = [];

    public function __construct(StreamInterface $stream)
    {
        $this->stream = $stream;
    }

    /**
     * Called when there is a new frame from the stream
     *
     * @param callable $onNewFrame
     */
    public function onFrame(callable $onNewFrame)
    {
        $this->onNewFrameCallables[] = $onNewFrame;
    }

    /**
     * Read a frame in the stream
     *
     * @return mixed
     */
    abstract protected function readFrame();

    /**
     * Wait for stream to finish and call callables if defined
     */
    public function wait()
    {
        while (!$this->stream->eof()) {
            $frame = $this->readFrame();

            if ($frame !== null) {
                if (!is_array($frame)) {
                    $frame = [$frame];
                }

                foreach ($this->onNewFrameCallables as $newFrameCallable) {
                    call_user_func_array($newFrameCallable, $frame);
                }
            }
        }
    }

    public function closeAndRead()
    {
        $this->stream->close();
        $this->wait();
    }
}