ожидание ответа на asyn c запрос и возврат данных - PullRequest
0 голосов
/ 25 января 2020

У меня есть функция, при которой мне нужно отправлять два сообщения через 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();
    }

}
...