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)
def data_received ( self , data ) : 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().
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 () .