eee

.phpstorm.meta.php

@@ -12,6 +12,6 @@ namespace PHPSTORM_META {
 //    override(\make(0), map('@'));
     override(\di(0), map('@'));
     override(\duplicate(0), map('@'));
-    override(Context::getContext(0), map('@'));
+    override(Context::get(0), map('@'));
 
 }

EventDispatch.php

@@ -1,13 +1,12 @@
 <?php
+declare(strict_types=1);
 
 namespace Kiri\Events;
 
-use Kiri;
 use Kiri\Abstracts\Component;
-use Psr\Container\ContainerExceptionInterface;
-use Psr\Container\NotFoundExceptionInterface;
 use Psr\EventDispatcher\EventDispatcherInterface;
 use Psr\EventDispatcher\StoppableEventInterface;
+use SplPriorityQueue;
 
 
 /**
@@ -18,39 +17,36 @@ class EventDispatch extends Component implements EventDispatcherInterface
 
 
 	/**
-	 * @param EventProvider $eventProvider
+	 * @param object $event
-	 * @param array $config
+	 * @return object
-	 * @throws \Exception
      */
-	public function __construct(public EventProvider $eventProvider, array $config = [])
+	public function dispatch(object $event): object
 	{
-		parent::__construct($config);
+		$lists = make(EventProvider::class)->getListenersForEvent($event);
+
+		return $this->execute($lists, $event);
 	}
 
 
     /**
+     * @param SplPriorityQueue $lists
      * @param object $event
      * @return object
-	 * @throws ContainerExceptionInterface
-	 * @throws NotFoundExceptionInterface
      */
-	public function dispatch(object $event): object
+	public function execute(SplPriorityQueue $lists, object $event): object
 	{
-		$lists = $this->eventProvider->getListenersForEvent($event);
+		if ($lists->isEmpty()) {
-		if (!$lists->valid()) {
 			return $event;
 		}
-		$lists->top();
+        foreach ($lists as $item)  {
-		while ($lists->valid()) {
             try {
-				call_user_func($lists->current(), $event);
+                call_user_func($item, $event);
             } catch (\Throwable $exception) {
-				$this->logger->error($exception->getMessage(), [$exception]);
+                error($exception);
             }
             if ($event instanceof StoppableEventInterface && $event->isPropagationStopped()) {
                 break;
             }
-			$lists->next();
         }
 		return $event;
 	}

EventInterface.php

@@ -0,0 +1,13 @@
+<?php
+
+namespace Kiri\Events;
+
+interface EventInterface
+{
+
+    /**
+     * @return void
+     */
+    public function process(): void;
+
+}

EventProvider.php

@@ -1,8 +1,10 @@
 <?php
+declare(strict_types=1);
 
 namespace Kiri\Events;
 
 
+use Closure;
 use Psr\EventDispatcher\ListenerProviderInterface;
 use SplPriorityQueue;
 
@@ -34,11 +36,11 @@ class EventProvider implements ListenerProviderInterface
 
     /**
      * @param string $event
-	 * @param array|\Closure|string $handler
+     * @param array|Closure|string $handler
      * @param int $zOrder
-	 * @throws \Exception
+     * @throws
      */
-	public function on(string $event, array|\Closure|string $handler, int $zOrder = 1)
+    public function on(string $event, array|Closure|string $handler, int $zOrder = 1): void
     {
         if (is_string($handler) && !is_callable($handler, true)) {
             throw new \Exception('Event handler must is execute function.');

Struct.php

@@ -16,6 +16,12 @@ class Struct
 
 	public int $priority;
 
+
+    /**
+     * @param string $event
+     * @param array|\Closure|string $listener
+     * @param int $priority
+     */
 	public function __construct(string $event, array|\Closure|string $listener, int $priority)
 	{
 		$this->event = $event;

TestListener.php

@@ -0,0 +1,17 @@
+<?php
+
+namespace Kiri\Events;
+
+class TestListener implements EventInterface
+{
+
+
+    /**
+     * @return void
+     */
+    public function process(): void
+    {
+        // TODO: Implement process() method.
+    }
+
+}