def run()

in pythonflow/pfmq/_base.py [0:0]


    def run(self):
        """
        Run the event loop.

        Notes
        -----
        This call is blocking.
        """
        raise NotImplementedError