Run unasync

Author: zanieb

httpcore/_sync/http2.py

@@ -143,10 +143,14 @@ def handle_request(self, request: Request) -> Response:
                 # a GOAWAY event. Other flows of control may then raise
                 # a protocol error at any point they interact with the 'h2_state'.
                 #
-                # In this case we'll have stored the event, and should raise
-                # it as a RemoteProtocolError.
+                # In this case we'll have stored the event, and should raise it.
                 if self._connection_error_event:
-                    raise RemoteProtocolError(self._connection_error_event)
+                    if isinstance(
+                        self._connection_error_event, h2.events.ConnectionTerminated
+                    ):
+                        raise ConnectionNotAvailable(self._connection_error_event)
+                    else:
+                        raise RemoteProtocolError(self._connection_error_event)
                 # If h2 raises a protocol error in some other state then we
                 # must somehow have made a protocol violation.
                 raise LocalProtocolError(exc)  # pragma: nocover
@@ -279,7 +283,7 @@ def _receive_events(
     ) -> None:
         with self._read_lock:
             if self._connection_error_event is not None:  # pragma: nocover
-                raise RemoteProtocolError(self._connection_error_event)
+                raise ConnectionNotAvailable(self._connection_error_event)
 
             # This conditional is a bit icky. We don't want to block reading if we've
             # actually got an event to return for a given stream. We need to do that

tests/_sync/test_http2.py

@@ -83,6 +83,9 @@ def test_http2_connection_closed():
         with pytest.raises(RemoteProtocolError):
             conn.request("GET", "https://example.com/")
 
+        with pytest.raises(ConnectionNotAvailable):
+            conn.request("GET", "https://example.com/")
+
         assert not conn.is_available()
 
 
@@ -219,7 +222,7 @@ def test_http2_connection_with_goaway():
     with HTTP2Connection(origin=origin, stream=stream) as conn:
         with pytest.raises(RemoteProtocolError):
             conn.request("GET", "https://example.com/")
-        with pytest.raises(RemoteProtocolError):
+        with pytest.raises(ConnectionNotAvailable):
             conn.request("GET", "https://example.com/")