8 Commits

Author SHA1 Message Date
as2252258 df7b50563f Revert "改名"
This reverts commit fdf58326
2022-01-12 14:10:33 +08:00
as2252258 b5f20d7d4b Revert "改名"
This reverts commit fdf58326
2022-01-10 11:39:56 +08:00
as2252258 244e84772e e 2022-01-09 13:57:10 +08:00
as2252258 9529907710 1 2022-01-09 02:44:08 +08:00
as2252258 2c31bea602 Revert "改名"
This reverts commit fdf58326
2022-01-08 18:49:07 +08:00
as2252258 fd01c8b33c Revert "改名"
This reverts commit fdf58326
2022-01-04 16:04:22 +08:00
as2252258 47979c6eab 改名 2021-12-08 11:32:32 +08:00
as2252258 cee00f58e3 改名 2021-12-03 15:44:06 +08:00
6 changed files with 158 additions and 165 deletions
+34 -34
View File
@@ -1,34 +1,34 @@
# Created by .ignore support plugin (hsz.mobi)
### Yii template
assets/*
!assets/.gitignore
protected/runtime/*
!protected/runtime/.gitignore
protected/data/*.db
themes/classic/views/
### Example user template template
### Example user template
# IntelliJ project files
.idea
*.iml
out
gen
composer.lock
*.log
commands/result
config/setting.php
tests/
vendor/
runtime/
*.xml
*.lock
oot
d
composer.lock
# Created by .ignore support plugin (hsz.mobi)
### Yii template
assets/*
!assets/.gitignore
protected/runtime/*
!protected/runtime/.gitignore
protected/data/*.db
themes/classic/views/
### Example user template template
### Example user template
# IntelliJ project files
.idea
*.iml
out
gen
composer.lock
*.log
commands/result
config/setting.php
tests/
vendor/
runtime/
*.xml
*.lock
oot
d
composer.lock
+17 -17
View File
@@ -1,17 +1,17 @@
<?php
namespace PHPSTORM_META {
// Reflect
use Http\Context\Context;
use Kiri\Di\Container;
override(Container::get(0), map('@'));
override(Container::newObject(0), map('@'));
// override(\Hyperf\Utils\Context::get(0), map('@'));
// override(\make(0), map('@'));
override(\di(0), map('@'));
override(\duplicate(0), map('@'));
override(Context::getContext(0), map('@'));
}
<?php
namespace PHPSTORM_META {
// Reflect
use Kiri\Message\Context\Context;
use Kiri\Di\Container;
override(Container::get(0), map('@'));
override(Container::newObject(0), map('@'));
// override(\Hyperf\Utils\Context::get(0), map('@'));
// override(\make(0), map('@'));
override(\di(0), map('@'));
override(\duplicate(0), map('@'));
override(Context::getContext(0), map('@'));
}
+37 -42
View File
@@ -1,42 +1,37 @@
<?php
namespace Kiri\Events;
use Note\Inject;
use Kiri\Abstracts\BaseObject;
use Psr\EventDispatcher\EventDispatcherInterface;
use Psr\EventDispatcher\StoppableEventInterface;
/**
*
*/
class EventDispatch extends BaseObject implements EventDispatcherInterface
{
/**
* @var EventProvider
*/
#[Inject(EventProvider::class)]
public EventProvider $eventProvider;
/**
* @param object $event
* @return object
*/
public function dispatch(object $event): object
{
$lists = $this->eventProvider->getListenersForEvent($event);
foreach ($lists as $listener) {
/** @var Struct $list */
$listener($event);
if ($event instanceof StoppableEventInterface && $event->isPropagationStopped()) {
break;
}
}
return $event;
}
}
<?php
namespace Kiri\Events;
use Kiri\Abstracts\Component;
use Kiri;
use Psr\EventDispatcher\EventDispatcherInterface;
use Psr\EventDispatcher\StoppableEventInterface;
/**
*
*/
class EventDispatch extends Component implements EventDispatcherInterface
{
/**
* @param object $event
* @return object
* @throws \ReflectionException
*/
public function dispatch(object $event): object
{
$lists = $this->eventProvider->getListenersForEvent($event);
foreach ($lists as $listener) {
/** @var Struct $list */
$listener($event);
if ($event instanceof StoppableEventInterface && $event->isPropagationStopped()) {
break;
}
}
return $event;
}
}
+44 -44
View File
@@ -1,44 +1,44 @@
<?php
namespace Kiri\Events;
use Psr\EventDispatcher\ListenerProviderInterface;
/**
*
*/
class EventProvider implements ListenerProviderInterface
{
/** @var Struct[] */
private array $_listeners = [];
/**
* @param object $event
* @return iterable
*/
public function getListenersForEvent(object $event): iterable
{
$queue = new \SplPriorityQueue();
// TODO: Implement getListenersForEvent() method.
foreach ($this->_listeners[get_class($event)] ?? [] as $listener) {
$queue->insert($listener->listener, $listener->priority);
}
return $queue;
}
/**
* @param string $event
* @param callable $handler
* @param int $zOrder
*/
public function on(string $event, callable $handler, int $zOrder = 1)
{
$this->_listeners[$event][] = new Struct($event, $handler, $zOrder);
}
}
<?php
namespace Kiri\Events;
use Psr\EventDispatcher\ListenerProviderInterface;
/**
*
*/
class EventProvider implements ListenerProviderInterface
{
/** @var Struct[] */
private array $_listeners = [];
/**
* @param object $event
* @return iterable
*/
public function getListenersForEvent(object $event): iterable
{
$queue = new \SplPriorityQueue();
// TODO: Implement getListenersForEvent() method.
foreach ($this->_listeners[get_class($event)] ?? [] as $listener) {
$queue->insert($listener->listener, $listener->priority);
}
return $queue;
}
/**
* @param string $event
* @param callable $handler
* @param int $zOrder
*/
public function on(string $event, callable $handler, int $zOrder = 1)
{
$this->_listeners[$event][] = new Struct($event, $handler, $zOrder);
}
}
+25 -25
View File
@@ -1,25 +1,25 @@
<?php
declare(strict_types=1);
namespace Kiri\Events;
/**
*
*/
class Struct
{
public string $event;
public array|\Closure $listener;
public int $priority;
public function __construct(string $event, callable $listener, int $priority)
{
$this->event = $event;
$this->listener = $listener;
$this->priority = $priority;
}
}
<?php
declare(strict_types=1);
namespace Kiri\Events;
/**
*
*/
class Struct
{
public string $event;
public array|\Closure $listener;
public int $priority;
public function __construct(string $event, callable $listener, int $priority)
{
$this->event = $event;
$this->listener = $listener;
$this->priority = $priority;
}
}
+1 -3
View File
@@ -10,15 +10,13 @@
"license": "MIT",
"require": {
"php": ">=8.0",
"ext-json": "*",
"psr/event-dispatcher": "^1.0"
},
"autoload": {
"psr-4": {
"Kiri\\Events\\": "src/"
"Kiri\\Events\\": "./"
}
},
"require-dev": {
"kwn/php-rdkafka-stubs": "^2.0"
}
}