Lines 100.00% 3 / 3
Functions and Methods 100.00% 3 / 3
Classes and Traits 100.00% 1 / 1
Name Lines Functions and Methods CRAP Classes and Traits
CorrelatedReplyHandler 100.00% 3 / 3 100.00% 3 / 3 3 100.00% 1 / 1
 __construct 100.00% 1 / 1 100.00% 1 / 1 1
 handledMessageClass 100.00% 1 / 1 100.00% 1 / 1 1
 handle 100.00% 1 / 1 100.00% 1 / 1 1
1<?php
2
3declare(strict_types=1);
4
5namespace Stewart\Runtime\Worker\Message;
6
7use Stewart\Runtime\Ipc\Message\BrokerMessage;
8use Stewart\Runtime\Ipc\Message\CorrelatedReply;
9use Stewart\Runtime\Worker\PendingRequests;
10
11/** @implements BrokerMessageHandler<CorrelatedReply> */
12final readonly class CorrelatedReplyHandler implements BrokerMessageHandler
13{
14    public function __construct(private PendingRequests $pending) {}
15
16    public function handledMessageClass(): string
17    {
18        return CorrelatedReply::class;
19    }
20
21    /** @param CorrelatedReply $message */
22    public function handle(BrokerMessage $message): void
23    {
24        $this->pending->resolve($message->correlationId, $message->getAnswer());
25    }
26}