WyriHaximus\React\Http\Middleware\MeasureMiddlewareCollector

Complexity

Total Complexity

5

Size/Duplication

Total Lines	39
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	2

Test Coverage

Coverage

0%

Importance

Changes

0

3 Methods

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

<?php declare(strict_types=1);

namespace WyriHaximus\React\Http\Middleware;

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

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

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

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

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

        return observableFromArray($metrics);
    }

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