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

This package is auto-updated.

Last update: 2024-09-24 20:42:43 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!"
});