WyriHaximus\React\Inspector\Http\Middleware\MeasureMiddlewareCollector

Complexity

Total Complexity

5

Size/Duplication

Total Lines	36
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	2

Test Coverage

Coverage

78.56%

Importance

Changes

0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	register()	0	4	1
A	collect()	0	20	3
A	cancel()	0	4	1

<?php declare(strict_types=1);

namespace WyriHaximus\React\Inspector\Http\Middleware;

use Rx\ObservableInterface;
use WyriHaximus\React\Http\Middleware\MeasureMiddleware;
use WyriHaximus\React\Inspector\CollectorInterface;
use WyriHaximus\React\Inspector\Metric;
use function ApiClients\Tools\Rx\observableFromArray;

final class MeasureMiddlewareCollector implements CollectorInterface
{
    /** @var MeasureMiddleware[] */
    private $middleware = [];

    public function register(string $key, MeasureMiddleware $middleware)
    {
        $this->middleware[$key] = $middleware;
    }

    public function collect(): ObservableInterface
    {
        $metrics = [];

        /**
         * @var string            $key
         * @var MeasureMiddleware $middleware
         */
        foreach ($this->middleware as $key => $middleware) {
            /** @var Metric $metric */
            foreach ($middleware->collect() as $metricKey => $metricValue) {
                $metrics[] = new Metric(
                    $key . '.' . $metricKey,
                    $metricValue
                );
            }
        }

        return observableFromArray($metrics);
    }

    public function cancel(): void
    {
        $this->middleware = [];
    }
}