WyriHaximus\React\ChildProcess\Messenger\Messages\RpcError

Complexity

Total Complexity

4

Size/Duplication

Total Lines	45
Duplicated Lines	0 %

Test Coverage

Coverage

100%

Importance

Changes	1
Bugs	0	Features	0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	jsonSerialize()	0	6	1
A	__construct()	0	4	1
A	getPayload()	0	3	1
A	handle()	0	13	1

<?php

declare(strict_types=1);

namespace WyriHaximus\React\ChildProcess\Messenger\Messages;

use Closure;
use Exception;
use JsonSerializable;
use Throwable;
use WyriHaximus\React\ChildProcess\Messenger\MessengerInterface;

final class RpcError implements JsonSerializable, ActionableMessageInterface
{
    protected string $uniqid;

    protected Throwable $payload;

    public function __construct(string $uniqid, Throwable $payload)
    {
        $this->uniqid  = $uniqid;
        $this->payload = $payload;
    }

    /**
     * @return Exception|Throwable
     */
    public function getPayload()
    {
        return $this->payload;
    }

    /**
     * @return array<string,string|mixed>
     */
    public function jsonSerialize(): array
    {
        return [
            'type' => 'rpc_error',
            'uniqid' => $this->uniqid,
            'payload' => LineEncoder::encode($this->payload),
        ];
    }

    public function handle(MessengerInterface $bindTo, string $source): void
    {
        $cb = Closure::fromCallable(function (Throwable $payload, string $uniqid): void {
            /**
             * @psalm-suppress UndefinedMethod
             */
            $this->getOutstandingCall($uniqid)->reject($payload); /** @phpstan-ignore-line  */

The method getOutstandingCall() does not exist on WyriHaximus\React\ChildProcess\Messenger\Messages\RpcError.

        });
        $cb = $cb->bindTo($bindTo);
        /**
         * @psalm-suppress PossiblyInvalidFunctionCall
         */
        $cb($this->payload, $this->uniqid);
    }
}