(self, queue: str)
| 352 | assert await r.decode() == "hi", r |
| 353 | |
| 354 | async def test_invalid(self, queue: str) -> None: |
| 355 | router = self.router_class() |
| 356 | |
| 357 | app = FastAPI() |
| 358 | |
| 359 | args, kwargs = self.get_subscriber_params(queue) |
| 360 | |
| 361 | @router.subscriber(*args, **kwargs) |
| 362 | async def hello(msg: int) -> None: ... |
| 363 | |
| 364 | app.include_router(router) |
| 365 | |
| 366 | async with self.patch_broker(router.broker) as br: |
| 367 | with TestClient(app): |
| 368 | with pytest.raises(RequestValidationError): |
| 369 | await br.publish("hi", queue) |
| 370 | |
| 371 | async def test_headers(self, queue: str) -> None: |
| 372 | router = self.router_class() |
nothing calls this directly
no test coverage detected