CallbackStream::wait() - Code Metrics - Inspection of "[WIP] Refactoring of Docker-PHP" - stage1/docker-php - Measure and Improve Code Quality continuously with Scrutinizer

Completed

Pull Request — master (#147)

by Joel

created 2016-01-10 13:33 UTC

CallbackStream::wait() B

↳ Parent: CallbackStream

Complexity

Conditions	5
Paths	6

Size

Total Lines	16
Code Lines	8

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	13
CRAP Score	5

Importance

Changes	3
Bugs	0	Features	3

Metric	Value
c	3
b	0
f	3
dl	0
loc	16
ccs	13
cts	13
cp	1
rs	8.8571
cc	5
eloc	8
nc	6
nop	0
crap	5

<?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();
    }
}


1		<?php
2
3		namespace Docker\Stream;
4
5		use Psr\Http\Message\StreamInterface;
6
7		abstract class CallbackStream
8		{
9		protected $stream;
10
11		private $onNewFrameCallables = [];
12
13	8	public function __construct(StreamInterface $stream)
14		{
15	8	$this->stream = $stream;
16	8	}
17
18		/**
19		* Called when there is a new frame from the stream
20		*
21		* @param callable $onNewFrame
22		*/
23	8	public function onFrame(callable $onNewFrame)
24		{
25	8	$this->onNewFrameCallables[] = $onNewFrame;
26	8	}
27
28		/**
29		* Read a frame in the stream
30		*
31		* @return mixed
32		*/
33		abstract protected function readFrame();
34
35		/**
36		* Wait for stream to finish and call callables if defined
37		*/
38	8	public function wait()
39		{
40	8	while (!$this->stream->eof()) {
41	8	$frame = $this->readFrame();
42
43	8	if ($frame !== null) {
44	8	if (!is_array($frame)) {
45	8	$frame = [$frame];
46	8	}
47
48	8	foreach ($this->onNewFrameCallables as $newFrameCallable) {
49	8	call_user_func_array($newFrameCallable, $frame);
50	8	}
51	8	}
52	8	}
53	8	}
54
55		public function closeAndRead()
56		{
57		$this->stream->close();
58		$this->wait();
59		}
60		}
61

stage1 / docker-php

Pull Request — master (#147)

CallbackStream::wait() B

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like