Method Next

c++/src/Compression.cc:253–270

  }

  bool CompressionStream::Next(void** data, int* size) {
    if (rawInputBuffer.size() > compressionBlockSize) {
      std::stringstream ss;
      ss << "uncompressed data size " << rawInputBuffer.size()
         << " is larger than compression block size " << compressionBlockSize;
      throw CompressionError(ss.str());
    }

    // compress data in the rawInputBuffer when it is full
    if (rawInputBuffer.size() == compressionBlockSize) {
      compressInternal();
    }

    auto block = rawInputBuffer.getNextBlock();
    *data = block.data;
    *size = static_cast<int>(block.size);
    return true;
  }

  class ZlibCompressionStream : public CompressionStream {
   public: