This commit is contained in:
2021-03-23 11:27:33 +08:00
parent fe31c36bac
commit b39e4a466b
+10 -6
View File
@@ -75,13 +75,15 @@ class Router extends HttpService implements RouterInterface
* @param $port * @param $port
* @param Closure|array|string $closure * @param Closure|array|string $closure
* @param null $method * @param null $method
* @throws * @return mixed
* @throws Exception
*/ */
public function addPortListen($port, Closure|array|string $closure, $method = null) public function addPortListen($port, Closure|array|string $closure, $method = null): mixed
{ {
if (!is_string($closure)) { try {
$this->addRoute('add-port-listen/port_' . $port, $closure, 'listen'); if (!is_string($closure)) {
} else { return $this->addRoute('add-port-listen/port_' . $port, $closure, 'listen');
}
if (empty($method)) { if (empty($method)) {
throw new NotFindClassException($closure . '::' . $method); throw new NotFindClassException($closure . '::' . $method);
} }
@@ -89,7 +91,9 @@ class Router extends HttpService implements RouterInterface
if (!method_exists($_closure, $method)) { if (!method_exists($_closure, $method)) {
throw new NotFindClassException($closure . '::' . $method); throw new NotFindClassException($closure . '::' . $method);
} }
$this->addRoute('add-port-listen/port_' . $port, [$_closure, $method], 'listen'); return $this->addRoute('add-port-listen/port_' . $port, [$_closure, $method], 'listen');
} catch (\Throwable $exception) {
return $this->addError($exception);
} }
} }