as2252258/kiri-rpc
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 1 Wiki Activity

改名

Browse Source
This commit is contained in:
向林
2021-12-02 15:26:43 +08:00
parent 439e3c566e
commit 23206bc683
1 changed files with 3 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/RpcJsonp.php
+3
View File
@@ -94,6 +94,9 @@ class RpcJsonp extends Component implements OnConnectInterface, OnReceiveInterfa
*/ */
public function consulWatches(OnWorkerStart|OnTaskerStart $server) public function consulWatches(OnWorkerStart|OnTaskerStart $server)
{ {
if ($server->workerId != 0) {
return;
}
Timer::tick(1000, static function () { Timer::tick(1000, static function () {
Kiri::getDi()->get(RpcManager::class)->tick(); Kiri::getDi()->get(RpcManager::class)->tick();
}); });