ReactPHP/Socket server - установить тайм-аут соединения

Question

У меня есть TCP-сервер Socket, используя response \ socket.

В зависимости от полученных данных от клиента, он что-то делает, а затем закрывает соединение с клиентом.

Проблема в том, что я не могу понять, как установить время ожидания соединения, , если сервер не получил никаких данных за определенный период времени, как закрыть соединение?

Я ищу такой же, как я сделал с stream_socket_accept() с помощью stream_set_timeout()

<?php 

require __DIR__ . '/vendor/autoload.php'; 

$loop = React\EventLoop\Factory::create(); 
$socket = new React\Socket\Server($loop); 

$socket->listen(2222); 

$socket->on('connection', function ($conn) { 

    $conn->on('data', function ($data) use ($conn) { 

     if (substr($data, 0, 3) == 'one') { 
      $conn->end('end_two'); 
     } 
     else if (substr($data, 0, 3) == 'two') { 
      $conn->end('end_two'); 
     } 
     else { 
      $conn->close(); 
     } 
    }); 

}); 
$loop->run(); 
stream_set_timeout($client, 5); 

Answer 1

Вам нужно добавить таймер для вашего $loop, как в приведенном ниже примере.

$loop = React\EventLoop\Factory::create(); 

$socket = new React\Socket\Server($loop); 
$socket->on('connection', function ($conn) use ($loop) { 
    $func = function() use ($conn) {$conn->close();}; 
    $timer = $loop->addTimer(1, $func); 
    $conn->on('data', function ($data) use ($loop, &$timer, $func) { 
     $timer->cancel(); 
     $timer = $loop->addTimer(1, $func); 
    }); 
}); 

Пример из:

https://github.com/reactphp/socket/issues/42