def run()

in pypubsub.py [0:0]


    def run(self):
        loop = asyncio.get_event_loop()
        # add a signal handler for SIGUSR2 to reload the ACL from disk
        try:
            loop.add_signal_handler(signal.SIGUSR2, self.load_acl)
        except ValueError:
            pass
        try:
            loop.run_until_complete(self.server_loop(loop))
        except KeyboardInterrupt:
            pass
        loop.close()