()
| 10 | # Close the connection when receiving SIGTERM. |
| 11 | loop = asyncio.get_running_loop() |
| 12 | def close(): |
| 13 | return loop.create_task(websocket.close()) |
| 14 | loop.add_signal_handler(signal.SIGTERM, close) |
| 15 | |
| 16 | # Process messages received on the connection. |
nothing calls this directly
no test coverage detected
searching dependent graphs…