This commit is contained in:
2020-12-14 15:34:59 +08:00
parent 7c40a35679
commit b278c028c3
7 changed files with 39 additions and 19 deletions
+9 -10
View File
@@ -41,10 +41,10 @@ class OnTask extends Callback
* @param int $from_id * @param int $from_id
* @param string $data * @param string $data
* *
* @return mixed|void * @return mixed
* @throws Exception 异步任务 * @throws Exception 异步任务
*/ */
public function onTask(Server $server, int $task_id, int $from_id, string $data) public function onTask(Server $server, int $task_id, int $from_id, string $data): mixed
{ {
$time = microtime(TRUE); $time = microtime(TRUE);
if (empty($data)) { if (empty($data)) {
@@ -59,17 +59,16 @@ class OnTask extends Callback
'runTime' => microtime(TRUE) - $time, 'runTime' => microtime(TRUE) - $time,
'endTime' => microtime(TRUE), 'endTime' => microtime(TRUE),
]; ];
$server->finish(json_encode($finish)); return $server->finish(json_encode($finish));
} }
/** /**
* @param Server $server * @param Server $server
* @param Server\Task $task * @param Server\Task $task
* @return mixed|void * @return mixed
* @throws Exception * @throws Exception 异步任务
* 异步任务
*/ */
public function onContinueTask(Server $server, Server\Task $task) public function onContinueTask(Server $server, Server\Task $task): mixed
{ {
$time = microtime(TRUE); $time = microtime(TRUE);
if (empty($task->data)) { if (empty($task->data)) {
@@ -84,7 +83,7 @@ class OnTask extends Callback
'runTime' => microtime(TRUE) - $time, 'runTime' => microtime(TRUE) - $time,
'endTime' => microtime(TRUE), 'endTime' => microtime(TRUE),
]; ];
$task->finish(json_encode($finish)); return $task->finish(json_encode($finish));
} }
/** /**
@@ -92,7 +91,7 @@ class OnTask extends Callback
* @return array|null * @return array|null
* @throws Exception * @throws Exception
*/ */
private function runTaskHandler($data) private function runTaskHandler($data): ?array
{ {
$serialize = $this->before($data); $serialize = $this->before($data);
try { try {
@@ -135,7 +134,7 @@ class OnTask extends Callback
* @param $exception * @param $exception
* @return string * @return string
*/ */
private function format($exception) private function format($exception): string
{ {
return $exception->getMessage() . " on line " . $exception->getLine() . " at file " . $exception->getFile(); return $exception->getMessage() . " on line " . $exception->getLine() . " at file " . $exception->getFile();
} }
+1 -1
View File
@@ -17,6 +17,6 @@ interface After
* @param $params * @param $params
* @return mixed * @return mixed
*/ */
public function onHandler(Request $request, $params); public function onHandler(Request $request, $params): mixed;
} }
+7 -3
View File
@@ -21,9 +21,13 @@ interface IFormatter
* @param $context * @param $context
* @return static * @return static
*/ */
public function send($context); public function send($context): static;
public function getData();
public function clear(); /**
* @return mixed
*/
public function getData(): mixed;
public function clear(): void;
} }
+6 -1
View File
@@ -12,6 +12,11 @@ interface Interceptor
{ {
public function Interceptor(Request $request, Closure $closure); /**
* @param Request $request
* @param Closure $closure
* @return mixed
*/
public function Interceptor(Request $request, Closure $closure): mixed;
} }
+6 -1
View File
@@ -11,6 +11,11 @@ use Closure;
interface Limits interface Limits
{ {
public function next(Request $request, Closure $closure); /**
* @param Request $request
* @param Closure $closure
* @return mixed
*/
public function next(Request $request, Closure $closure): mixed;
} }
+8 -1
View File
@@ -5,6 +5,7 @@ declare(strict_types=1);
namespace HttpServer\IInterface; namespace HttpServer\IInterface;
use Closure;
use HttpServer\Http\Request; use HttpServer\Http\Request;
/** /**
@@ -14,6 +15,12 @@ use HttpServer\Http\Request;
interface Middleware interface Middleware
{ {
public function handler(Request $request,\Closure $next);
/**
* @param Request $request
* @param Closure $next
* @return mixed
*/
public function handler(Request $request, Closure $next): mixed;
} }
+2 -2
View File
@@ -21,8 +21,8 @@ interface Task
/** /**
* @return void * @return mixed
*/ */
public function onHandler(): void; public function onHandler(): mixed;
} }