thesis/sync-once

Thesis Sync Once

Maintainers

Details

github.com/thesis-php/sync-once

Source

Issues

Fund package maintenance!
www.tinkoff.ru/cf/5MqZQas2dk7

Installs: 1 084

Dependents: 2

Suggesters: 0

Security: 0

Stars: 0

Watchers: 2

Forks: 0

Open Issues: 0

0.1.1 2025-05-07 18:30 UTC

Requires

Requires (Dev)

MIT bccfddbb8192a013a61c5a19502f4a99e180200c

  • Valentin Udaltsov <udaltsov.valentin.woop@gmail.com>
  • Thesis Team

This package is auto-updated.

Last update: 2025-05-07 19:59:32 UTC

README

PHP Version Requirement GitHub Release Code Coverage Mutation testing badge

Installation

composer require thesis/sync-once

Usage

use Amp\TimeoutCancellation;
use Thesis\Amqp\Channel;
use Thesis\Amqp\Client;
use Thesis\Amqp\Message;
use Thesis\Sync\Once;

final readonly class AmqpTransport
{
    /**
     * @var Once<Channel>
     */
    private Once $publishChannel;

    public function __construct(
        private Client $client,
    ) {
        $this->publishChannel = new Once(
            // make sure to use static closures to avoid circular references
            function: static fn (): Channel => $client->channel(),
            isAlive: static fn (Channel $channel): bool => !$channel->isClosed(),
        );
    }

    public function publish(Message $message): void
    {
        $this
            ->publishChannel
            ->await(new TimeoutCancellation(10))
            ->publish($message);
    }
}