Daikon\MessageBus\Channel\Subscription\LazySubscription

Complexity

Total Complexity

7

Size/Duplication

Total Lines	55
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	5

Test Coverage

Coverage

0%

Importance

Changes

0

<?php declare(strict_types=1);

    private Closure $factoryCallback;

    public function __construct(
        string $key,
        Closure $transport,
        Closure $messageHandlers,
        Closure $guard = null,
        Closure $metadataEnrichers = null
    ) {
        $this->key = $key;
        $this->factoryCallback = fn(): SubscriptionInterface =>

A parse error occurred: Syntax error, unexpected ':', expecting T_DOUBLE_ARROW on line 31 at column 37

            new Subscription(
                $this->key,
                $transport(),
                $messageHandlers(),
                $guard,
                $metadataEnrichers ? $metadataEnrichers() : null
            );
    }

    public function publish(EnvelopeInterface $envelope, MessageBusInterface $messageBus): void
    {
        if ($subscription = $this->getSubscription()) {
            $subscription->publish($envelope, $messageBus);
        }
    }

    public function receive(EnvelopeInterface $envelope): void
    {
        if ($subscription = $this->getSubscription()) {
            $subscription->receive($envelope);
        }
    }

    public function getKey(): string
    {
        return $this->key;
    }

    private function getSubscription(): SubscriptionInterface
    {
        /** @psalm-suppress TypeDoesNotContainType */
        if (!isset($this->compositeSubscription)) {
            $this->compositeSubscription = call_user_func($this->factoryCallback);
            unset($this->factoryCallback);
        }
        return $this->compositeSubscription;
    }
}