Emitter::withBufferSize() - Code Metrics - razonyang/psr7-swoole - Measure and Improve Code Quality continuously with Scrutinizer

Emitter::withBufferSize() A
last analyzed 2022-09-24 08:45 UTC

↳ Parent: Emitter

Complexity

Conditions	1
Paths	1

Size

Total Lines	6
Code Lines	3

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	0
CRAP Score	2

Importance

Changes	1
Bugs	0	Features	0

Metric	Value
cc	1
eloc	3
c	1
b	0
f	0
nc	1
nop	1
dl	0
loc	6
ccs	0
cts	4
cp	0
crap	2
rs	10

<?php

declare(strict_types=1);

namespace RazonYang\Psr7\Swoole;

use Psr\Http\Message\ResponseInterface;
use Psr\Http\Message\StreamInterface;
use Swoole\Http\Response;

final class Emitter implements EmitterInterface
{
    public function __construct(
        private Response $response,
        private int $bufferSize = 8_388_608, // 8MB

    ) {
    }

    public function withBufferSize(int $size)
    {
        $new = clone $this;
        $new->bufferSize = $size;

        return $new;
    }

    public function getBufferSize(): int
    {
        return $this->bufferSize;
    }

    public function emit(ResponseInterface $response, bool $withoutBody = false)
    {
        $this->response->status($response->getStatusCode(), $response->getReasonPhrase());

        foreach ($response->getHeaders() as $key => $value) {
            $this->response->header($key, $value);
        }

        if (!$withoutBody) {
            $this->emitBody($response->getBody());
        }

        $this->response->end();
    }

    private function emitBody(StreamInterface $body): void
    {
        if ($body->isSeekable()) {
            $body->rewind();
        }

        while (!$body->eof()) {
            $this->response->write($body->read($this->bufferSize));
        }
    }
}


1			<?php
2
3			declare(strict_types=1);
4
5			namespace RazonYang\Psr7\Swoole;
6
7			use Psr\Http\Message\ResponseInterface;
8			use Psr\Http\Message\StreamInterface;
9			use Swoole\Http\Response;
10
11			final class Emitter implements EmitterInterface
12			{
13			public function __construct(
14			private Response $response,
15			private int $bufferSize = 8_388_608, // 8MB
			0 ignored issues – show Bug introduced 2022-09-17 06:05 UTC by Report Bug Copy Issue Report The constant `RazonYang\Psr7\Swoole\8_388_608` was not found. Maybe you did not declare it correctly or list all dependencies? Loading history...
16			) {
17			}
18
19			public function withBufferSize(int $size)
20			{
21			$new = clone $this;
22			$new->bufferSize = $size;
23
24			return $new;
25			}
26
27			public function getBufferSize(): int
28			{
29			return $this->bufferSize;
30			}
31
32			public function emit(ResponseInterface $response, bool $withoutBody = false)
33			{
34			$this->response->status($response->getStatusCode(), $response->getReasonPhrase());
35
36			foreach ($response->getHeaders() as $key => $value) {
37			$this->response->header($key, $value);
38			}
39
40			if (!$withoutBody) {
41			$this->emitBody($response->getBody());
42			}
43
44			$this->response->end();
45			}
46
47			private function emitBody(StreamInterface $body): void
48			{
49			if ($body->isSeekable()) {
50			$body->rewind();
51			}
52
53			while (!$body->eof()) {
54			$this->response->write($body->read($this->bufferSize));
55			}
56			}
57			}
58

razonyang / psr7-swoole

Emitter::withBufferSize() A last analyzed 2022-09-24 08:45 UTC

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like

Emitter::withBufferSize() A
last analyzed 2022-09-24 08:45 UTC