diff --git a/src/danog/MadelineProto/DataCenter.php b/src/danog/MadelineProto/DataCenter.php index a044f775..4a5c58a9 100644 --- a/src/danog/MadelineProto/DataCenter.php +++ b/src/danog/MadelineProto/DataCenter.php @@ -31,8 +31,6 @@ use Amp\Http\Client\Cookie\CookieJar; use Amp\Http\Client\Cookie\InMemoryCookieJar; use Amp\Http\Client\DelegateHttpClient; use Amp\Http\Client\HttpClientBuilder; -use Amp\Http\Client\Interceptor\ModifyRequest; -use Amp\Http\Client\Interceptor\RemoveRequestHeader; use Amp\Http\Client\Request; use Amp\Socket\ConnectContext; use Amp\Websocket\Client\Rfc6455Connector; diff --git a/src/danog/MadelineProto/Stream/Transport/WsStream.php b/src/danog/MadelineProto/Stream/Transport/WsStream.php index 8f18d70d..d008c250 100644 --- a/src/danog/MadelineProto/Stream/Transport/WsStream.php +++ b/src/danog/MadelineProto/Stream/Transport/WsStream.php @@ -69,7 +69,7 @@ class WsStream implements RawStreamInterface, ProxyStreamInterface $this->dc = $ctx->getIntDc(); $handshake = new Handshake(\str_replace('tcp://', $ctx->isSecure() ? 'wss://' : 'ws://', $ctx->getStringUri())); - + $this->stream = yield ($this->connector ?? connector())->connect($handshake, $ctx->getCancellationToken()); yield $this->write($header);