def on_receive(self, message):
        if 'close' in message:
            self.connection.stop('Client most likely disconnected.')
            return

        if 'received' not in message:
            return

        self.connection.disable_timeout()
        self.recv_buffer += message['received']

        for line in self.parse_lines():
            line = self.decode(line)
            if line is not None:
                self.on_line_received(line)

        if not self.prevent_timeout:
            self.connection.enable_timeout()
Finalize retry executor.
dataset/ETHPy150Open mopidy/mopidy/mopidy/internal/network.py/LineProtocol.on_receive--crossover with--dataset/ETHPy150Open openstack/taskflow/taskflow/engines/action_engine/executor.py/SerialRetryExecutor.stop