Lint; add cast for return type

Author: zanieb

httpcore/_async/http11.py

@@ -8,8 +8,8 @@
     Optional,
     Tuple,
     Type,
-    cast,
     Union,
+    cast,
 )
 
 import h11
@@ -194,7 +194,7 @@ async def _receive_event(self, timeout: float = None) -> h11.Event:
                 # TODO: Implement handling for paused
                 ...
             else:
-                return event
+                return cast(h11.Event, event)
 
     async def _response_closed(self) -> None:
         async with self._state_lock:

httpcore/_sync/http11.py

@@ -61,9 +61,7 @@ def handle_request(self, request: Request) -> Response:
                 self._send_request_headers(**kwargs)
             with Trace("http11.send_request_body", request, kwargs) as trace:
                 self._send_request_body(**kwargs)
-            with Trace(
-                "http11.receive_response_headers", request, kwargs
-            ) as trace:
+            with Trace("http11.receive_response_headers", request, kwargs) as trace:
                 (
                     http_version,
                     status,
@@ -158,12 +156,13 @@ def _receive_event(self, timeout: float = None) -> h11.Event:
         while True:
             with map_exceptions({h11.RemoteProtocolError: RemoteProtocolError}):
                 # The h11 type signature uses a private return type
-                event = cast(Union[h11.Event, h11.NEED_DATA, h11.PAUSED], self._h11_state.next_event())
+                event = cast(
+                    Union[h11.Event, h11.NEED_DATA, h11.PAUSED],
+                    self._h11_state.next_event(),
+                )
 
             if event is h11.NEED_DATA:
-                data = self._network_stream.read(
-                    self.READ_NUM_BYTES, timeout=timeout
-                )
+                data = self._network_stream.read(self.READ_NUM_BYTES, timeout=timeout)
 
                 # If we feed this case through h11 we'll raise an exception like:
                 #
@@ -182,7 +181,7 @@ def _receive_event(self, timeout: float = None) -> h11.Event:
                 # TODO: Implement handling for paused
                 ...
             else:
-                return event
+                return cast(h11.Event, event)
 
     def _response_closed(self) -> None:
         with self._state_lock: