Docker\Stream\CallbackStream

Complexity

Total Complexity

6

Size/Duplication

Total Lines	44
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	1

Importance

Changes	1
Bugs	0	Features	1

4 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
A	onFrame()	0	4	1
	readFrame()	0	1	?
A	wait()	0	12	4

<?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) {

                foreach ($this->onNewFrameCallables as $newFrameCallable) {

                    $newFrameCallable($frame);

                }

            }

        }

    }

}