pinoven/event-dispatcher

在 oven 中的 PSR 事件标准实现。

dev-master 2020-08-01 16:36 UTC

This package is auto-updated.

Last update: 2024-09-29 05:22:26 UTC


README

兼容 PSR-14: Event Dispatcher。实现事件分发器来分发事件。它提供了一种注册监听器和订阅/取消订阅多个监听器提供商的方法。分发器可以通过聚合器通过不同的提供商检索监听器。

特性/用法

分发器

    use Pinoven\Dispatcher\Dispatch\EventDispatcher;
    use Pinoven\Dispatcher\Provider\AggregatorProvider;
    use Pinoven\Dispatcher\Samples\EventSampleA;
 
    $aggregator = new AggregatorProvider();
    $eventDispatcher =  new EventDispatcher($aggregator);
    $event = new EventSampleA();
    $eventDispatcher->dispatch($event);

聚合器、代理、映射设置

    use Fig\EventDispatcher\DelegatingProvider as FigDelegatingProvider;
    use Pinoven\Dispatcher\Listener\ProxyListeners;
    use Pinoven\Dispatcher\Provider\AggregatorProvider;
    use Pinoven\Dispatcher\Provider\DelegatingProvider;
    use Pinoven\Dispatcher\Samples\EventMapperProviderSample;
    use Pinoven\Dispatcher\Samples\EventMapperProviderSampleB;
    use Pinoven\Dispatcher\Samples\EventMapperProviderSampleC;
    use Pinoven\Dispatcher\Samples\EventSampleA;
 
    $aggregator = new AggregatorProvider();
    $proxy = new ProxyListeners();
    $defaultListenerProvider = new FigDelegatingProvider();
    $eventMapper1 = new  EventMapperProviderSample($proxy);
    $eventMapper2 = new  EventMapperProviderSampleB($proxy);
    $eventMapper3 = new  EventMapperProviderSampleC($proxy);
    $defaultListenerProvider->addProvider($eventMapper3, [EventSampleA::class]);
    $delegateListenerProvider1 = new DelegatingProvider();
    $delegateListenerProvider1->subscribe($eventMapper1);
    $delegateListenerProvider1->subscribe($eventMapper2);
    // \Pinoven\Dispatcher\Provider\DelegatingType() Can take a default listenerProvider.
    $delegateListenerProvider2 = new DelegatingProvider($defaultListenerProvider);
    $aggregator->addProvider($delegateListenerProvider1);
    $aggregator->addProvider($delegateListenerProvider2);

事件/监听器映射器

use Pinoven\Dispatcher\Event\EventListenersMapper;
EventListenersMapper::class;

它有助于声明事件类型和相关监听器。

use Pinoven\Dispatcher\Event\EventListenersMapper;
EventListenersMapper::class;

发射事件

use Pinoven\Dispatcher\Event\EventEmitter;
EventEmitter::class;

发射器事件允许使用分发器并通过字符串和有效载荷发送自定义事件。

顺序/优先级

顺序项目

要管理提供商上的排序、您必须实现的监听器

use Pinoven\Dispatcher\Priority\PrioritizeInterface;
class Prioritize implements PrioritizeInterface 
{
    public function sortItems(iterable $items) : iterable
    {
        // Code ...
         return  $items;
    }
}

查看实现

use Pinoven\Dispatcher\Priority\Prioritize;
$prioritize = new Prioritize();

处理优先级

如果监听器是一个类,则它应该实现

use Pinoven\Dispatcher\Priority\ItemPriorityInterface;
ItemPriorityInterface::class;

如果您的监听器/可调用不能直接实现此接口,您可以使用

use Pinoven\Dispatcher\Priority\CallableInterface;
CallableInterface::class;

您可能需要在包装器上做一些事情,因此您可以使用工厂将您的监听器/可调用转换为包装器项。

use Pinoven\Dispatcher\Priority\CallableItemPriorityInterface;
CallableItemPriorityInterface::class;

待办事项

  • 如果 public $payload 是公共的,则合并有效载荷或向现有有效载荷添加数据
  • 自动事件层次结构。这意味着通过处理 BeforeEvent、AfterEvent。也许 BetweenEvent.??
  • 实现日志记录器
  • 实现容器
  • 实现 CacheInterface
  • 附加/分离监听器?
  • 实现自己的集合/生成器
  • 清洁示例

贡献

  • 创建问题:改进 + 应该实现的原因或问题 + 如何复现。
  • 创建拉取请求并解释问题。

有关如何在所有 pinoven 包上贡献的更多信息将陆续推出。