CallbackStream::wait() - Code Metrics - Inspection of "Add stream for attach, and add attach websocket" - stage1/docker-php - Measure and Improve Code Quality continuously with Scrutinizer

Completed

Push — 1.x ( d4bf15...1f27e1 )

by Joel

created 2016-01-09 22:06 UTC

CallbackStream::wait() B

↳ Parent: CallbackStream

Complexity

Conditions	5
Paths	6

Size

Total Lines	16
Code Lines	8

Duplication

Lines	0
Ratio	0 %

Importance

Changes	3
Bugs	0	Features	3

Metric	Value
c	3
b	0
f	3
dl	0
loc	16
rs	8.8571
cc	5
eloc	8
nc	6
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) {
                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			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			if (!is_array($frame)) {
45			$frame = [$frame];
46			}
47
48			foreach ($this->onNewFrameCallables as $newFrameCallable) {
49			call_user_func_array($newFrameCallable, $frame);
50			}
51			}
52			}
53			}
54
55			public function closeAndRead()
56			{
57			$this->stream->close();
58			$this->wait();
59			}
60			}
61

stage1 / docker-php

Push — 1.x ( d4bf15...1f27e1 )

CallbackStream::wait() B

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like