cs-fix
This commit is contained in:
parent
069c599a7c
commit
3690339424
@ -31,8 +31,6 @@ use Amp\Http\Client\Cookie\CookieJar;
|
|||||||
use Amp\Http\Client\Cookie\InMemoryCookieJar;
|
use Amp\Http\Client\Cookie\InMemoryCookieJar;
|
||||||
use Amp\Http\Client\DelegateHttpClient;
|
use Amp\Http\Client\DelegateHttpClient;
|
||||||
use Amp\Http\Client\HttpClientBuilder;
|
use Amp\Http\Client\HttpClientBuilder;
|
||||||
use Amp\Http\Client\Interceptor\ModifyRequest;
|
|
||||||
use Amp\Http\Client\Interceptor\RemoveRequestHeader;
|
|
||||||
use Amp\Http\Client\Request;
|
use Amp\Http\Client\Request;
|
||||||
use Amp\Socket\ConnectContext;
|
use Amp\Socket\ConnectContext;
|
||||||
use Amp\Websocket\Client\Rfc6455Connector;
|
use Amp\Websocket\Client\Rfc6455Connector;
|
||||||
|
@ -69,7 +69,7 @@ class WsStream implements RawStreamInterface, ProxyStreamInterface
|
|||||||
$this->dc = $ctx->getIntDc();
|
$this->dc = $ctx->getIntDc();
|
||||||
|
|
||||||
$handshake = new Handshake(\str_replace('tcp://', $ctx->isSecure() ? 'wss://' : 'ws://', $ctx->getStringUri()));
|
$handshake = new Handshake(\str_replace('tcp://', $ctx->isSecure() ? 'wss://' : 'ws://', $ctx->getStringUri()));
|
||||||
|
|
||||||
$this->stream = yield ($this->connector ?? connector())->connect($handshake, $ctx->getCancellationToken());
|
$this->stream = yield ($this->connector ?? connector())->connect($handshake, $ctx->getCancellationToken());
|
||||||
|
|
||||||
yield $this->write($header);
|
yield $this->write($header);
|
||||||
|
Loading…
Reference in New Issue
Block a user