hhpack/publisher

Hack的简单Pub/Sub实现

安装次数: 487

依赖者: 2

建议者: 0

安全: 0

星标: 2

关注者: 1

分支: 0

开放问题: 0

语言:Shell

1.3.0 2019-04-15 03:31 UTC

README

Hack的简单Pub/Sub实现。

Latest Stable Version CircleCI Dependency Status License

基本用法

用法非常简单,您只需实现 MessageSubscriber
以下代码注册到 MessagePublisher 并发布消息。

namespace domain;

use HHPack\Publisher\Message;
use HHPack\Publisher\Subscribable;
use HHPack\Publisher\MessagePublisher;

final class DomainMessage implements Message
{
}

final class DomainMessageSubscriber implements Subscribable<Message>
{
  public async function onDomainMessage(DomainMessage $message) : Awaitable<void>
  {
    await async_task1();
    await async_task2();
  }
}

$publisher = new MessagePublisher();
$publisher->registerSubscriber(new DomainMessageSubscriber());

await $publisher->publish(new DomainMessage());

运行测试

您可以使用以下命令运行测试。

composer install
composer test