(sock)
| 1273 | |
| 1274 | def run(meth): |
| 1275 | def wrapper(sock): |
| 1276 | try: |
| 1277 | meth(sock) |
| 1278 | except Exception as ex: |
| 1279 | self.loop.call_soon_threadsafe(future.set_exception, ex) |
| 1280 | else: |
| 1281 | self.loop.call_soon_threadsafe(future.set_result, None) |
| 1282 | return wrapper |
| 1283 | |
| 1284 | async def client(addr): |
nothing calls this directly
no test coverage detected