dev-master 2019-04-20 20:16 UTC

This package is auto-updated.

Last update: 2024-11-24 20:56:38 UTC


README

Компонент реализует PubSub-сервис, используемый для рассылки сообщений (событий) по каналам.

Конфигурация

Пример использования

Рассылка

$pubsub = $this->app->factory('PubSub');
$pubsub->publish(new \Zer0\PubSub\Message('someChannel', 'Hello world!'));

Подписка (асинхронный вариант)

$pubsub = $this->app->factory('PubSubAsync');

// Подписка на определенный канал
$pubsub->subscribe('someChannel', function ($payload, string $chan) {
    var_dump($payload);
   // string(12) "Hello world!"
});

// Подписка по шаблону
$pubsub->psubscribe('some*', function ($payload, string $chan) {
   var_dump($payload);
   // string(12) "Hello world!"
});