for testing and deploying your application
for finding and fixing issues
for empowering human code reviews
<?php
namespace EventSauce\EventSourcing;
final class SynchronousMessageDispatcher implements MessageDispatcher
{
/**
* @var Consumer[]
*/
private $consumers;
public function __construct(Consumer ... $consumers)
$this->consumers = $consumers;
}
public function dispatch(Message ... $messages)
foreach ($messages as $message) {
foreach ($this->consumers as $consumer) {
$consumer->handle($message);
EventSaucePHP /
EventSauce
