<?php

use OpenSwoole\Coroutine;

Coroutine::run(function () {

$client = new \OpenSwoole\Coroutine\Http\Client('0.0.0.0', 8080);

$client->setHeaders([

"User-Agent" => 'Chrome/49.0.2587.3',

'Accept' => 'text/html,application/xhtml+xml,application/xml',

'Accept-Encoding' => 'gzip, deflate, br',

'Sec-WebSocket-Protocol' => 'wamp.2.json, wamp.2.msgpack'

]);

$upgraded = $client->upgrade('/');

Coroutine::create(function () use ($upgraded) {

if ($upgraded) {

}

});

Coroutine::create(function () use ($client) {

while ($client->connected) {

Coroutine::usleep(1);

$data = $client->recv();

Coroutine::create(function (\OpenSwoole\WebSocket\Frame $frame) {

echo 'Received: ' . $frame->data . PHP_EOL;

}, $data);

}

});

});