def __init__(self, gen, callback):
        self._callback = callback

        super(SyncRunner, self).__init__(gen)
Messages are delimited by MSG_DELIM. The buffer could have grown by
dataset/ETHPy150Open mrjoes/tornadio2/tornadio2/gen.py/SyncRunner.__init__--crossover with--dataset/ETHPy150Open ncclient/ncclient/ncclient/transport/ssh.py/SSHSession._parse10