(self)
| 306 | return (await self._actual_headers()).get(name) |
| 307 | |
| 308 | async def _actual_headers(self) -> "RawHeaders": |
| 309 | override = self._fallback_overrides.headers |
| 310 | if override: |
| 311 | return RawHeaders(serialize_headers(override)) |
| 312 | if not self._all_headers_future: |
| 313 | self._all_headers_future = asyncio.Future() |
| 314 | headers = await self._channel.send( |
| 315 | "rawRequestHeaders", None, is_internal=True |
| 316 | ) |
| 317 | self._all_headers_future.set_result(RawHeaders(headers)) |
| 318 | return await self._all_headers_future |
| 319 | |
| 320 | def _target_closed_future(self) -> asyncio.Future: |
| 321 | frame = cast( |
no test coverage detected