highfive/master.py
def data_received(self, data):
        """
        Called when a chunk of data is received from the remote worker. These
        chunks are stored in a buffer. When a complete line is found in the
        buffer, it removed and sent to line_received().
        """

        self._buffer.extend(data)
        while True:
            i = self._buffer.find(b"\n")
            if i == -1:
                break
            line = self._buffer[:i+1]
            self._buffer = self._buffer[i+1:]
            self.line_received(line)
def data_received(self, data):
        """
        Called when a chunk of data is received from the remote worker. These
        chunks are stored in a buffer. When a complete line is found in the
        buffer, it removed and sent to line_received().
        """

        self._buffer.extend(data)
        while True:
            i = self._buffer.find(b"\n")
            if i == -1:
                break
            line = self._buffer[:i+1]
            self._buffer = self._buffer[i+1:]
            self.line_received(line)
Called when a chunk of data is received from the remote worker. These
        chunks are stored in a buffer. When a complete line is found in the
        buffer, it removed and sent to line_received().