WritableStreamHash::__construct() - Code Metrics - Inspection of "Emit also with the hash event" - WyriHaximus/reactphp-stream-hash - Measure and Improve Code Quality continuously with Scrutinizer

Completed

Push — master ( 80e1a2...dbc788 )

by Cees-Jan

created 2017-07-07 06:09 UTC

WritableStreamHash::__construct() A

↳ Parent: WritableStreamHash

Complexity

Conditions	1
Paths	1

Size

Total Lines	11
Code Lines	7

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	9
CRAP Score	1

Importance

Changes

Metric	Value
dl	0
loc	11
ccs	9
cts	9
cp	1
rs	9.4285
c	0
b	0
f	0
cc	1
eloc	7
nc	1
nop	4
crap	1

<?php declare(strict_types=1);

namespace WyriHaximus\React\Stream\Hash;

use Evenement\EventEmitter;
use React\Stream\WritableStreamInterface;

final class WritableStreamHash extends EventEmitter implements WritableStreamInterface
{
    /**
     * @var WritableStreamInterface
     */
    private $stream;

    /**
     * @var resource
     */
    private $context;

    /**
     * WritableStreamHash constructor.
     * @param WritableStreamInterface $stream
     */
    public function __construct(WritableStreamInterface $stream, string $algo, int $options = 0, string $key = '')
    {
        $this->stream = $stream;
        $this->context = hash_init($algo, $options, $key);
        $this->stream->once('close', function () use ($algo) {
            $this->emit('hash', [
                hash_final($this->context),
                $algo,
            ]);
        });
    }

    public function isWritable()
    {
        return $this->stream->isWritable();
    }

    public function write($data)
    {
        hash_update($this->context, $data);

        return $this->stream->write($data);
    }

    public function end($data = null)
    {
        if ($data !== null) {
            hash_update($this->context, $data);
        }
        $this->stream->end($data);
    }

    public function close()
    {
        $this->stream->close();
    }
}


1		<?php declare(strict_types=1);
2
3		namespace WyriHaximus\React\Stream\Hash;
4
5		use Evenement\EventEmitter;
6		use React\Stream\WritableStreamInterface;
7
8		final class WritableStreamHash extends EventEmitter implements WritableStreamInterface
9		{
10		/**
11		* @var WritableStreamInterface
12		*/
13		private $stream;
14
15		/**
16		* @var resource
17		*/
18		private $context;
19
20		/**
21		* WritableStreamHash constructor.
22		* @param WritableStreamInterface $stream
23		*/
24	184	public function __construct(WritableStreamInterface $stream, string $algo, int $options = 0, string $key = '')
25		{
26	184	$this->stream = $stream;
27	184	$this->context = hash_init($algo, $options, $key);
28	184	$this->stream->once('close', function () use ($algo) {
29	184	$this->emit('hash', [
30	184	hash_final($this->context),
31	184	$algo,
32		]);
33	184	});
34	184	}
35
36		public function isWritable()
37		{
38		return $this->stream->isWritable();
39		}
40
41	184	public function write($data)
42		{
43	184	hash_update($this->context, $data);
44
45	184	return $this->stream->write($data);
46		}
47
48	184	public function end($data = null)
49		{
50	184	if ($data !== null) {
51		hash_update($this->context, $data);
52		}
53	184	$this->stream->end($data);
54	184	}
55
56		public function close()
57		{
58		$this->stream->close();
59		}
60		}
61

WyriHaximus / reactphp-stream-hash

GitHub Access Token became invalid

Push — master ( 80e1a2...dbc788 )

WritableStreamHash::__construct() A

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like