This commit is contained in:
2021-03-08 17:23:16 +08:00
parent 85ebf7d795
commit ac275ed032
+4 -4
View File
@@ -79,7 +79,9 @@ class Router extends HttpService implements RouterInterface
*/ */
public function addPortListen($port, Closure|array|string $closure, $method = null) public function addPortListen($port, Closure|array|string $closure, $method = null)
{ {
if (is_string($closure)) { if (!is_string($closure)) {
$this->addRoute('add-port-listen/port_' . $port, $closure, 'listen');
} else {
if (empty($method)) { if (empty($method)) {
throw new NotFindClassException($closure . '::' . $method); throw new NotFindClassException($closure . '::' . $method);
} }
@@ -87,10 +89,8 @@ 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');
$closure = [$closure, $method];
} }
$this->addRoute('add-port-listen/port_' . $port, $closure, 'listen');
} }