def run(self):
        self.loop = asyncio.get_event_loop()
        self.coro = self.loop.create_server(self.factory, '127.0.0.1', self.port)
        self.server = self.loop.run_until_complete(self.coro)

        try:
            self.loop.run_forever()
        except __HOLE__:
            pass
        finally:
            self.server.close()
            self.loop.close()
dataset/ETHPy150Open ekulyk/PythonPusherClient/tests/pusherserver/pusherserverasyncio.py/Pusher.run