У меня есть функция, при которой мне нужно отправлять два сообщения через websocket и возвращаться только при получении ответов.
Мне трудно работать с этим.
Что бы быть правильным путем?
$GLOBALS['loop'] = \React\EventLoop\Factory::create();
$GLOBALS['connector'] = new \Ratchet\Client\Connector($GLOBALS['loop']);
class Binary {
public static function test() {
$connector = $GLOBALS['connector'];
$loop = $GLOBALS['loop'];
$connector('wss://ws.XXX')->then(function ($conn) use ($loop) {
$conn->send("xxx");
$conn->send('yyy');
$conn->on('message', function ($msg) {
return $msg; //I need you to wait for the reply from both $conn->send()
});
}, function ($e) {
echo "Could not connect: {$e->getMessage()}\n";
});
$loop->run();
}
}