'Read \'size\' bytes from remote.'

def read(self, size):

    if (self.decompressor is None):
        return os.read(self.read_fd, size)
    if self.decompressor.unconsumed_tail:
        data = self.decompressor.unconsumed_tail
    else:
        data = os.read(self.read_fd, READ_SIZE)
    return self.decompressor.decompress(data, size)
