(reader, writer)
| 1227 | |
| 1228 | def test_unhandled_exception(self): |
| 1229 | async def handle_echo(reader, writer): |
| 1230 | raise Exception('test') |
| 1231 | messages = self._basetest_unhandled_exceptions(handle_echo) |
| 1232 | self.assertEqual(messages[0]['message'], |
| 1233 | 'Unhandled exception in client_connected_cb') |