hhpack / publisher
Hack的简单Pub/Sub实现
1.3.0
2019-04-15 03:31 UTC
Requires
- hhvm: >=3.21.0
- hhvm/hhvm-autoload: ^2.0
Requires (Dev)
- facebook/fbexpect: ^2.5
- hhvm/hacktest: ^1.5
README
Hack的简单Pub/Sub实现。
基本用法
用法非常简单,您只需实现 Message 和 Subscriber。
以下代码注册到 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