Revert "改名"
This reverts commit fdf58326
This commit is contained in:
@@ -94,7 +94,6 @@ class RpcJsonp extends Component implements OnConnectInterface, OnReceiveInterfa
|
|||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
$async_time = (int)Config::get('consul.async_time', 1000);
|
$async_time = (int)Config::get('consul.async_time', 1000);
|
||||||
var_dump($async_time);
|
|
||||||
Timer::tick($async_time, static function ($timeId) {
|
Timer::tick($async_time, static function ($timeId) {
|
||||||
if (env('state', 'start') == 'exit') {
|
if (env('state', 'start') == 'exit') {
|
||||||
Timer::clear($timeId);
|
Timer::clear($timeId);
|
||||||
|
|||||||
+4
-1
@@ -68,14 +68,17 @@ class RpcManager extends Component
|
|||||||
|
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* @throws ReflectionException
|
|
||||||
* @throws Exception
|
* @throws Exception
|
||||||
*/
|
*/
|
||||||
public function tick(): void
|
public function tick(): void
|
||||||
{
|
{
|
||||||
|
try {
|
||||||
foreach ($this->_rpc as $name => $list) {
|
foreach ($this->_rpc as $name => $list) {
|
||||||
$this->async($name);
|
$this->async($name);
|
||||||
}
|
}
|
||||||
|
} catch (\Throwable $throwable) {
|
||||||
|
$this->logger()->error(error_trigger_format($throwable));
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user