def getstate(self):
        return self._state
When jobs are received pass them (decoded) to callback
dataset/ETHPy150Open coreemu/core/daemon/core/session.py/Session.getstate--crossover with--dataset/ETHPy150Open saltstack/salt/salt/transport/client.py/AsyncPubChannel.on_recv