CallbackStream::wait() - Code Metrics - Inspection of "Add a helper for build" - stage1/docker-php - Measure and Improve Code Quality continuously with Scrutinizer

Completed

Push — 1.x ( ee8545...084efb )

by Joel

created 2016-01-08 00:36 UTC

CallbackStream::wait() A

↳ Parent: CallbackStream

Complexity

Conditions	4
Paths	4

Size

Total Lines	12
Code Lines	6

Duplication

Lines	0
Ratio	0 %

Importance

Changes	1
Bugs	0	Features	1

Metric	Value
c	1
b	0
f	1
dl	0
loc	12
rs	9.2
cc	4
eloc	6
nc	4
nop	0

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


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			public function __construct(StreamInterface $stream)
14			{
15			$this->stream = $stream;
16			}
17
18			/**
19			* Called when there is a new frame from the stream
20			*
21			* @param callable $onNewFrame
22			*/
23			public function onFrame(callable $onNewFrame)
24			{
25			$this->onNewFrameCallables[] = $onNewFrame;
26			}
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			public function wait()
39			{
40			while (!$this->stream->eof()) {
41			$frame = $this->readFrame();
42
43			if ($frame !== null) {
44			foreach ($this->onNewFrameCallables as $newFrameCallable) {
45			$newFrameCallable($frame);
46			}
47			}
48			}
49			}
50			}
51

stage1 / docker-php

Push — 1.x ( ee8545...084efb )

CallbackStream::wait() A

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like