Fix: Apply ruff formatting

Author: drshvik

httpcore/_async/socks_proxy.py

@@ -57,10 +57,12 @@ async def _init_socks5_connection(
     )
     conn.send(socksio.socks5.SOCKS5AuthMethodsRequest([auth_method]))
     outgoing_bytes = conn.data_to_send()
-    await stream.write(outgoing_bytes, timeout=timeout) # <--- FIX 2: Pass timeout
+    await stream.write(outgoing_bytes, timeout=timeout)  # <--- FIX 2: Pass timeout
 
     # Auth method response
-    incoming_bytes = await stream.read(max_bytes=4096, timeout=timeout) # <--- FIX 3: Pass timeout
+    incoming_bytes = await stream.read(
+        max_bytes=4096, timeout=timeout
+    )  # <--- FIX 3: Pass timeout
     response = conn.receive_data(incoming_bytes)
     assert isinstance(response, socksio.socks5.SOCKS5AuthReply)
     if response.method != auth_method:
@@ -76,10 +78,12 @@ async def _init_socks5_connection(
         username, password = auth
         conn.send(socksio.socks5.SOCKS5UsernamePasswordRequest(username, password))
         outgoing_bytes = conn.data_to_send()
-        await stream.write(outgoing_bytes, timeout=timeout) # <--- FIX 4: Pass timeout
+        await stream.write(outgoing_bytes, timeout=timeout)  # <--- FIX 4: Pass timeout
 
         # Username/password response
-        incoming_bytes = await stream.read(max_bytes=4096, timeout=timeout) # <--- FIX 5: Pass timeout
+        incoming_bytes = await stream.read(
+            max_bytes=4096, timeout=timeout
+        )  # <--- FIX 5: Pass timeout
         response = conn.receive_data(incoming_bytes)
         assert isinstance(response, socksio.socks5.SOCKS5UsernamePasswordReply)
         if not response.success:
@@ -92,10 +96,12 @@ async def _init_socks5_connection(
         )
     )
     outgoing_bytes = conn.data_to_send()
-    await stream.write(outgoing_bytes, timeout=timeout) # <--- FIX 6: Pass timeout
+    await stream.write(outgoing_bytes, timeout=timeout)  # <--- FIX 6: Pass timeout
 
     # Connect response
-    incoming_bytes = await stream.read(max_bytes=4096, timeout=timeout) # <--- FIX 7: Pass timeout
+    incoming_bytes = await stream.read(
+        max_bytes=4096, timeout=timeout
+    )  # <--- FIX 7: Pass timeout
     response = conn.receive_data(incoming_bytes)
     assert isinstance(response, socksio.socks5.SOCKS5Reply)
     if response.reply_code != socksio.socks5.SOCKS5ReplyCode.SUCCEEDED:
@@ -211,7 +217,7 @@ async def handle_async_request(self, request: Request) -> Response:
                         "host": self._remote_origin.host.decode("ascii"),
                         "port": self._remote_origin.port,
                         "auth": self._proxy_auth,
-                        "timeout": timeout, # <--- FIX 8: Pass timeout argument
+                        "timeout": timeout,  # <--- FIX 8: Pass timeout argument
                     }
                     async with Trace(
                         "setup_socks5_connection", logger, request, kwargs
@@ -313,4 +319,4 @@ def info(self) -> str:
         return self._connection.info()
 
     def __repr__(self) -> str:
-        return f"<{self.__class__.__name__} [{self.info()}]>"
+        return f"<{self.__class__.__name__} [{self.info()}]>"