eee
This commit is contained in:
+12
-2
@@ -31,12 +31,22 @@ class Response implements ResponseInterface
|
|||||||
|
|
||||||
/**
|
/**
|
||||||
* 初始化
|
* 初始化
|
||||||
* @throws
|
|
||||||
*/
|
*/
|
||||||
public function __construct()
|
public function __construct()
|
||||||
{
|
{
|
||||||
$this->contentType = \config('response.content-type', ContentType::JSON);
|
$this->contentType = \config('response.content-type', ContentType::JSON);
|
||||||
$this->emmit = di(\config('response.emmit', SwooleHttpResponseEmitter::class));
|
$this->emmit = \config('response.emmit', SwooleHttpResponseEmitter::class);
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* @return void
|
||||||
|
* @throws ReflectionException
|
||||||
|
*/
|
||||||
|
public function init(): void
|
||||||
|
{
|
||||||
|
if (is_string($this->emmit)) {
|
||||||
|
$this->emmit = di($this->emmit);
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
|
|||||||
@@ -21,21 +21,6 @@ use SplPriorityQueue;
|
|||||||
class SwooleHttpResponseEmitter implements ResponseEmitterInterface
|
class SwooleHttpResponseEmitter implements ResponseEmitterInterface
|
||||||
{
|
{
|
||||||
|
|
||||||
|
|
||||||
/**
|
|
||||||
* @var EventProvider
|
|
||||||
*/
|
|
||||||
#[Container(EventProvider::class)]
|
|
||||||
public EventProvider $provider;
|
|
||||||
|
|
||||||
|
|
||||||
/**
|
|
||||||
* @var EventDispatch
|
|
||||||
*/
|
|
||||||
#[Container(EventDispatch::class)]
|
|
||||||
public EventDispatch $dispatch;
|
|
||||||
|
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* @var SplPriorityQueue
|
* @var SplPriorityQueue
|
||||||
*/
|
*/
|
||||||
@@ -49,9 +34,10 @@ class SwooleHttpResponseEmitter implements ResponseEmitterInterface
|
|||||||
|
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* @return void
|
* @param EventDispatch $dispatch
|
||||||
|
* @param EventProvider $provider
|
||||||
*/
|
*/
|
||||||
public function init(): void
|
public function __construct(readonly public EventDispatch $dispatch, readonly public EventProvider $provider)
|
||||||
{
|
{
|
||||||
$this->afterRequest = new OnAfterRequest();
|
$this->afterRequest = new OnAfterRequest();
|
||||||
$this->events = $this->provider->getListenersForEvent($this->afterRequest);
|
$this->events = $this->provider->getListenersForEvent($this->afterRequest);
|
||||||
|
|||||||
Reference in New Issue
Block a user