in pythonflow/pfmq/_base.py [0:0]
def run(self): """ Run the event loop. Notes ----- This call is blocking. """ raise NotImplementedError