Skip to content

Commit

Permalink
Fix pep8 issues
Browse files Browse the repository at this point in the history
  • Loading branch information
romis2012 committed Jul 14, 2020
1 parent 6b1ae0e commit cfa3470
Showing 1 changed file with 3 additions and 4 deletions.
7 changes: 3 additions & 4 deletions httpx_socks/core_socks/_stream_async_aio.py
Original file line number Diff line number Diff line change
Expand Up @@ -8,7 +8,6 @@


class SocketStream(AsyncSocketStream):

_loop: asyncio.AbstractEventLoop = None
_socket = None

Expand Down Expand Up @@ -44,7 +43,7 @@ async def write(self, request):
elif isinstance(item, (bytearray, bytes)):
data += item
else:
raise ValueError('Unsupported ' # pragma: no cover
raise ValueError('Unsupported ' # pragma: no cover
'request type')
await self._loop.sock_sendall(self._socket, data)

Expand All @@ -59,7 +58,7 @@ async def read_exact(self, n):
while len(data) < n:
packet = await self._loop.sock_recv(self._socket, n - len(data))
if not packet:
raise ProxyError('Connection closed ' # pragma: no cover
raise ProxyError('Connection closed ' # pragma: no cover
'unexpectedly')
data += packet
return data
Expand All @@ -69,7 +68,7 @@ async def read_all(self, buff_size=4096):
while True:
packet = await self._loop.sock_recv(self._socket, buff_size)
if not packet:
raise ProxyError('Connection closed ' # pragma: no cover
raise ProxyError('Connection closed ' # pragma: no cover
'unexpectedly')
data += packet
if len(packet) < buff_size:
Expand Down

0 comments on commit cfa3470

Please sign in to comment.