Как создать функцию с таймаутом на socket-сервере?

Question

[Давид]

Есть soket-сервер который работает на php (Rachet). Надо сделать отправку уведомлений по необходимости через каждые 30 секунд. Подскажите как реализовать правильнее?

Написал такую функцию, но она почему то не работает.

function timeoutNotify($start, $conn,$message){
    if(time() !== $start){ 
       return timeoutNotify($start, $conn, $message);
    }else{
        $conn->send(json_encode(['type' => 'notify', 'message' => $message]));
        return true;
    }
}

Для теста вызываю так:

$this->timeoutNotify(time()+5, $conn, 'Test message');

Answer 1

[Сергей Протько]

метод addPeriodicTimer

https://blog.wyrihaximus.net/2015/01/reactphp-timers/

Comments

[Давид]

После того как запускаю loop сервер "замирает". Насколько понимаю сервер просто отрабатывает только loop и больше ни на что не реагирует. или я что-то ни так сделал?

[Сергей Протько]

Давид: что-то не так сделали. Вам надо было использовать тот loop который юзает ratchet.

[Давид]

мой запуск "демона":
$server = IoServer::factory(
new WsServer(
new SocketRun()
)
, 8081
);

нашел такой манул :
$server->loop->addPeriodicTimer($time, function(){...});

а внутри "демона" (SocketRun) нет возможности добавлять что-то в loop?