ICanBoogie / MessageBus

lib/PSR/ContainerHandlerProvider.php

Indentation +27 added lines, -27 removed lines

@@ -20,31 +20,31 @@
 
 class ContainerHandlerProvider implements HandlerProvider
 {
-    /**
-     * @param array<string, string> $handlers
-     *     Where _key_ is a message class and _value_ the service identifier of its handler.
-     */
-    public function __construct(
-        private ContainerInterface $container,
-        private array $handlers
-    ) {
-        $this->container = $container;
-        $this->handlers = $handlers;
-    }
-
-    public function getHandlerForMessage(object $message): callable
-    {
-        $class = get_class($message);
-        $id = $this->handlers[$class] ?? null;
-
-        if (!$id) {
-            throw new NotFound("No handler for messages of type `$class`.");
-        }
-
-        try {
-            return $this->container->get($id); // @phpstan-ignore-line
-        } catch (NotFoundExceptionInterface $e) {
-            throw new NotFound("No handler for messages of type `$class`.", $e);
-        }
-    }
+	/**
+	 * @param array<string, string> $handlers
+	 *     Where _key_ is a message class and _value_ the service identifier of its handler.
+	 */
+	public function __construct(
+		private ContainerInterface $container,
+		private array $handlers
+	) {
+		$this->container = $container;
+		$this->handlers = $handlers;
+	}
+
+	public function getHandlerForMessage(object $message): callable
+	{
+		$class = get_class($message);
+		$id = $this->handlers[$class] ?? null;
+
+		if (!$id) {
+			throw new NotFound("No handler for messages of type `$class`.");
+		}
+
+		try {
+			return $this->container->get($id); // @phpstan-ignore-line
+		} catch (NotFoundExceptionInterface $e) {
+			throw new NotFound("No handler for messages of type `$class`.", $e);
+		}
+	}
 }

lib/AssertingDispatcher.php

Indentation +25 added lines, -25 removed lines

@@ -16,32 +16,32 @@
  */
 class AssertingDispatcher implements Dispatcher
 {
-    /**
-     * @var callable
-     */
-    private $assertion;
+	/**
+	 * @var callable
+	 */
+	private $assertion;
 
-    /**
-     * @param callable $assertion
-     *     A callable that should throw an exception if the message shouldn't be dispatched.
-     */
-    public function __construct(
-        private Dispatcher $dispatcher,
-        callable $assertion
-    ) {
-        $this->dispatcher = $dispatcher;
-        $this->assertion = $assertion;
-    }
+	/**
+	 * @param callable $assertion
+	 *     A callable that should throw an exception if the message shouldn't be dispatched.
+	 */
+	public function __construct(
+		private Dispatcher $dispatcher,
+		callable $assertion
+	) {
+		$this->dispatcher = $dispatcher;
+		$this->assertion = $assertion;
+	}
 
-    /**
-     * @param object $message
-     *
-     * @return mixed
-     */
-    public function dispatch(object $message)
-    {
-        ($this->assertion)($message);
+	/**
+	 * @param object $message
+	 *
+	 * @return mixed
+	 */
+	public function dispatch(object $message)
+	{
+		($this->assertion)($message);
 
-        return $this->dispatcher->dispatch($message);
-    }
+		return $this->dispatcher->dispatch($message);
+	}
 }