()
| 1088 | raise WebSocketClosedError() |
| 1089 | |
| 1090 | async def wrapper() -> None: |
| 1091 | try: |
| 1092 | await fut |
| 1093 | except StreamClosedError: |
| 1094 | raise WebSocketClosedError() |
| 1095 | |
| 1096 | return asyncio.ensure_future(wrapper()) |
| 1097 |
nothing calls this directly
no test coverage detected