def on_recv(self, callback):
        raise NotImplementedError()
When jobs are received pass them (decoded) to callback
dataset/ETHPy150Open saltstack/salt/salt/transport/client.py/AsyncPubChannel.on_recv