src/AppBundle/EventListener/EventPublisherListener.php line 20

Open in your IDE?
  1. <?php
  3. namespace AppBundle\EventListener;
  5. use CodersLab\Lms\SharedKernel\Domain\Bus\EventBus;
  6. use CodersLab\Lms\SharedKernel\Domain\Bus\IEventRecorder;
  7. use Symfony\Component\HttpKernel\Event\ResponseEvent;
  9. final class EventPublisherListener
  10. {
  11.     private EventBus $eventBus;
  12.     private IEventRecorder $eventRecorder;
  14.     public function __construct(EventBus $eventBus, IEventRecorder $eventRecorder)
  15.     {
  16.         $this->eventBus = $eventBus;
  17.         $this->eventRecorder = $eventRecorder;
  18.     }
  20.     public function __invoke(ResponseEvent $event): void
  21.     {
  22.         foreach ($this->eventRecorder->pullEvents() as $recordedEvent) {
  23.             $this->eventBus->notify($recordedEvent);
  24.         }
  25.     }
  26. }