改名
This commit is contained in:
@@ -106,7 +106,6 @@ class Node extends Application
|
|||||||
{
|
{
|
||||||
return Coroutine::create(function ($request, $response) {
|
return Coroutine::create(function ($request, $response) {
|
||||||
(Reduce::after($this->_after))($request, $response);
|
(Reduce::after($this->_after))($request, $response);
|
||||||
fire(Event::EVENT_AFTER_REQUEST);
|
|
||||||
}, \request(), $response);
|
}, \request(), $response);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@@ -7,6 +7,8 @@ namespace HttpServer\Route;
|
|||||||
use Closure;
|
use Closure;
|
||||||
use HttpServer\IInterface\After;
|
use HttpServer\IInterface\After;
|
||||||
use HttpServer\IInterface\Middleware;
|
use HttpServer\IInterface\Middleware;
|
||||||
|
use Snowflake\Core\Json;
|
||||||
|
use Snowflake\Event;
|
||||||
|
|
||||||
class Reduce
|
class Reduce
|
||||||
{
|
{
|
||||||
@@ -31,10 +33,15 @@ class Reduce
|
|||||||
{
|
{
|
||||||
return array_reduce(array_reverse($middleWares), function ($stack, $pipe) {
|
return array_reduce(array_reverse($middleWares), function ($stack, $pipe) {
|
||||||
return function ($request, $passable) use ($stack, $pipe) {
|
return function ($request, $passable) use ($stack, $pipe) {
|
||||||
if ($pipe instanceof After) {
|
try {
|
||||||
|
if (!($pipe instanceof After)) {
|
||||||
|
return call_user_func($pipe, $request, $passable, $stack);
|
||||||
|
}
|
||||||
return $pipe->onHandler($request, $passable);
|
return $pipe->onHandler($request, $passable);
|
||||||
} else {
|
} catch (\Throwable $throwable) {
|
||||||
return call_user_func($pipe, $request, $passable, $stack);
|
return Json::to(0, $throwable);
|
||||||
|
} finally {
|
||||||
|
fire(Event::EVENT_AFTER_REQUEST);
|
||||||
}
|
}
|
||||||
};
|
};
|
||||||
});
|
});
|
||||||
|
|||||||
Reference in New Issue
Block a user