@@ -196,7 +196,7 @@ def process_subprotocol(headers, available_subprotocols):
196196 return subprotocol
197197
198198 @asyncio .coroutine
199- def handshake (self , wsuri , origin = None , available_extensions = None ,
199+ def handshake (self , uri , origin = None , available_extensions = None ,
200200 available_subprotocols = None , extra_headers = None ):
201201 """
202202 Perform the client side of the opening handshake.
@@ -220,13 +220,13 @@ def handshake(self, wsuri, origin=None, available_extensions=None,
220220 set_header = lambda k , v : request_headers .append ((k , v ))
221221 is_header_set = lambda k : k in dict (request_headers ).keys ()
222222
223- if wsuri .port == (443 if wsuri .secure else 80 ): # pragma: no cover
224- set_header ('Host' , wsuri .host )
223+ if uri .port == (443 if uri .secure else 80 ): # pragma: no cover
224+ set_header ('Host' , uri .host )
225225 else :
226- set_header ('Host' , '{}:{}' .format (wsuri .host , wsuri .port ))
226+ set_header ('Host' , '{}:{}' .format (uri .host , uri .port ))
227227
228- if wsuri .user_info :
229- set_header (* basic_auth_header (* wsuri .user_info ))
228+ if uri .user_info :
229+ set_header (* basic_auth_header (* uri .user_info ))
230230
231231 if origin is not None :
232232 set_header ('Origin' , origin )
@@ -257,7 +257,7 @@ def handshake(self, wsuri, origin=None, available_extensions=None,
257257 key = build_request (set_header )
258258
259259 yield from self .write_http_request (
260- wsuri .resource_name , request_headers )
260+ uri .resource_name , request_headers )
261261
262262 status_code , response_headers = yield from self .read_http_response ()
263263 get_header = lambda k : response_headers .get (k , '' )
@@ -343,8 +343,8 @@ def __init__(self, uri, *,
343343 if create_protocol is None :
344344 create_protocol = WebSocketClientProtocol
345345
346- wsuri = parse_uri (uri )
347- if wsuri .secure :
346+ uri = parse_uri (uri )
347+ if uri .secure :
348348 kwds .setdefault ('ssl' , True )
349349 elif kwds .get ('ssl' ) is not None :
350350 raise ValueError ("connect() received a SSL context for a ws:// "
@@ -364,7 +364,7 @@ def __init__(self, uri, *,
364364 raise ValueError ("Unsupported compression: {}" .format (compression ))
365365
366366 factory = lambda : create_protocol (
367- host = wsuri .host , port = wsuri .port , secure = wsuri .secure ,
367+ host = uri .host , port = uri .port , secure = uri .secure ,
368368 timeout = timeout , max_size = max_size , max_queue = max_queue ,
369369 read_limit = read_limit , write_limit = write_limit ,
370370 loop = loop , legacy_recv = legacy_recv ,
@@ -373,12 +373,12 @@ def __init__(self, uri, *,
373373 )
374374
375375 if kwds .get ('sock' ) is None :
376- host , port = wsuri .host , wsuri .port
376+ host , port = uri .host , uri .port
377377 else :
378378 # If sock is given, host and port mustn't be specified.
379379 host , port = None , None
380380
381- self ._wsuri = wsuri
381+ self ._uri = uri
382382 self ._origin = origin
383383
384384 # This is a coroutine object.
@@ -398,7 +398,7 @@ def __await__(self):
398398
399399 try :
400400 yield from protocol .handshake (
401- self ._wsuri , origin = self ._origin ,
401+ self ._uri , origin = self ._origin ,
402402 available_extensions = protocol .available_extensions ,
403403 available_subprotocols = protocol .available_subprotocols ,
404404 extra_headers = protocol .extra_headers ,
0 commit comments