|
34 | 34 | from .haberdasher_pb2 import Hat, Size |
35 | 35 |
|
36 | 36 | if TYPE_CHECKING: |
37 | | - from collections.abc import AsyncIterator |
38 | | - |
39 | 37 | from connectrpc.request import RequestContext |
40 | 38 |
|
41 | 39 | _errors = [ |
@@ -455,9 +453,7 @@ async def make_hat(self, request, ctx) -> NoReturn: |
455 | 453 | @pytest.mark.asyncio |
456 | 454 | async def test_async_unhandled_exception_reraised_stream() -> None: |
457 | 455 | class RaisingHaberdasher(Haberdasher): |
458 | | - def make_similar_hats( |
459 | | - self, request: Size, ctx: RequestContext |
460 | | - ) -> AsyncIterator[Hat]: |
| 456 | + def make_similar_hats(self, request: Size, ctx: RequestContext) -> NoReturn: |
461 | 457 | raise TypeError("Something went wrong") |
462 | 458 |
|
463 | 459 | app = HaberdasherASGIApplication(RaisingHaberdasher()) |
@@ -497,9 +493,7 @@ async def make_hat(self, request, ctx) -> NoReturn: |
497 | 493 | @pytest.mark.asyncio |
498 | 494 | async def test_async_connect_exception_not_reraised_stream() -> None: |
499 | 495 | class RaisingHaberdasher(Haberdasher): |
500 | | - def make_similar_hats( |
501 | | - self, request: Size, ctx: RequestContext |
502 | | - ) -> AsyncIterator[Hat]: |
| 496 | + def make_similar_hats(self, request: Size, ctx: RequestContext) -> NoReturn: |
503 | 497 | raise ConnectError(Code.INTERNAL, "We're broken") |
504 | 498 |
|
505 | 499 | app = HaberdasherASGIApplication(RaisingHaberdasher()) |
|
0 commit comments