9555551525

Committed 17 Jun 2024 10:16PM UTC coverage: 70.262% (-1.1%) from 71.395%

Build # 9555551525

Build Type

push

github

Committed by

prolic

Commit Message

update coveralls repo token

Run Details

3466 of 4933 relevant lines covered (70.26%)

67.7 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

75.0

/src/Internal/MessageHandler.php

<?php

/**
 * This file is part of `prooph/event-store-client`.
 * (c) 2018-2024 Alexander Miertsch <kontakt@codeliner.ws>
 * (c) 2018-2024 Sascha-Oliver Prolic <saschaprolic@googlemail.com>
 *
 * For the full copyright and license information, please view the LICENSE
 * file that was distributed with this source code.
 */

declare(strict_types=1);

namespace Prooph\EventStoreClient\Internal;

use Closure;
use Prooph\EventStore\Exception\RuntimeException;
use Prooph\EventStoreClient\Internal\Message\Message;

/** @internal */
class MessageHandler
{
    /** @var array<string, Closure> */
    private array $handlers = [];

    public function registerHandler(string $messageName, Closure $handler): void
    {
        $this->handlers[$messageName] = $handler;
    }

    public function handle(Message $message): void
    {
        if (! isset($this->handlers[$message::class])) {
            throw new RuntimeException('No handler found for ' . $message::class);
        }

        $this->handlers[$message::class]($message);
    }
}

1	<?php
2
3	/**
4	* This file is part of `prooph/event-store-client`.
5	* (c) 2018-2024 Alexander Miertsch <kontakt@codeliner.ws>
6	* (c) 2018-2024 Sascha-Oliver Prolic <saschaprolic@googlemail.com>
7	*
8	* For the full copyright and license information, please view the LICENSE
9	* file that was distributed with this source code.
10	*/
11
12	declare(strict_types=1);
13
14	namespace Prooph\EventStoreClient\Internal;
15
16	use Closure;
17	use Prooph\EventStore\Exception\RuntimeException;
18	use Prooph\EventStoreClient\Internal\Message\Message;
19
20	/** @internal */
21	class MessageHandler
22	{
23	/** @var array<string, Closure> */
24	private array $handlers = [];
25
26	public function registerHandler(string $messageName, Closure $handler): void
27	{
28	$this->handlers[$messageName] = $handler;	420✔
29	}
30
31	public function handle(Message $message): void
32	{
33	if (! isset($this->handlers[$message::class])) {	408✔
34	throw new RuntimeException('No handler found for ' . $message::class);	×
35	}
36
37	$this->handlers[$message::class]($message);	408✔
38	}
39	}

prooph / event-store-client / 9555551525

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous