This commit is contained in:
2023-12-12 15:35:36 +08:00
parent f22a2a70b6
commit 7f5c4127e1
+42 -41
View File
@@ -4,6 +4,7 @@ declare(strict_types=1);
namespace Kiri\Events; namespace Kiri\Events;
use Closure;
use Psr\EventDispatcher\ListenerProviderInterface; use Psr\EventDispatcher\ListenerProviderInterface;
use SplPriorityQueue; use SplPriorityQueue;
@@ -13,54 +14,54 @@ use SplPriorityQueue;
class EventProvider implements ListenerProviderInterface class EventProvider implements ListenerProviderInterface
{ {
/** @var Struct[] */ /** @var Struct[] */
private array $_listeners = []; private array $_listeners = [];
/** /**
* @param object $event * @param object $event
* @return SplPriorityQueue * @return SplPriorityQueue
*/ */
public function getListenersForEvent(object $event): SplPriorityQueue public function getListenersForEvent(object $event): SplPriorityQueue
{ {
$queue = new SplPriorityQueue(); $queue = new SplPriorityQueue();
$queue->setExtractFlags(SplPriorityQueue::EXTR_DATA); $queue->setExtractFlags(SplPriorityQueue::EXTR_DATA);
// TODO: Implement getListenersForEvent() method. // TODO: Implement getListenersForEvent() method.
foreach ($this->_listeners[get_class($event)] ?? [] as $listener) { foreach ($this->_listeners[get_class($event)] ?? [] as $listener) {
$queue->insert($listener->listener, $listener->priority); $queue->insert($listener->listener, $listener->priority);
} }
return $queue; return $queue;
} }
/** /**
* @param string $event * @param string $event
* @param array|\Closure|string $handler * @param array|Closure|string $handler
* @param int $zOrder * @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)) { if (is_string($handler) && !is_callable($handler, true)) {
throw new \Exception('Event handler must is execute function.'); throw new \Exception('Event handler must is execute function.');
} }
$this->_listeners[$event][] = new Struct($event, $handler, $zOrder); $this->_listeners[$event][] = new Struct($event, $handler, $zOrder);
} }
/** /**
* @param string $event * @param string $event
* @param callable $handler * @param callable $handler
* @return void * @return void
*/ */
public function off(string $event, callable $handler): void public function off(string $event, callable $handler): void
{ {
$events = $this->_listeners[$event] ?? []; $events = $this->_listeners[$event] ?? [];
$this->_listeners[$event] = array_filter($events, function ($value) use ($handler) { $this->_listeners[$event] = array_filter($events, function ($value) use ($handler) {
return $value->listener !== $handler; return $value->listener !== $handler;
}); });
} }
} }