def _loop(self, barrier):
if sys.platform != "<STR_LIT:win32>":<EOL><INDENT>self.loop = asyncio.new_event_loop()<EOL><DEDENT>else:<EOL><INDENT>self.loop = asyncio.ProactorEventLoop()<EOL><DEDENT>asyncio.set_event_loop(self.loop)<EOL>barrier.wait()<EOL>try:<EOL><INDENT>self.loop.run_forever()<EOL><DEDENT>except Exception:<EOL><INDENT>sys.exit(<NUM_LIT:1>)<EOL><DEDENT>
Actual thread