packed_block_sink.hpp

Go to the documentation of this file.

 
#ifndef EAGINE_SERIALIZE_PACKED_BLOCK_SINK_HPP
#define EAGINE_SERIALIZE_PACKED_BLOCK_SINK_HPP
 
#include "../compression.hpp"
#include "block_sink.hpp"
 
namespace eagine {
//------------------------------------------------------------------------------
class packed_block_data_sink : public block_data_sink {
public:
    packed_block_data_sink() noexcept = default;
 
    packed_block_data_sink(
      data_compressor compressor,
      memory::block dst) noexcept
      : block_data_sink{dst}
      , _compressor{std::move(compressor)} {}
 
    packed_block_data_sink(memory::block dst) noexcept
      : packed_block_data_sink{{}, dst} {}
 
    packed_block_data_sink(data_compressor compressor) noexcept
      : packed_block_data_sink{std::move(compressor), {}} {}
 
    auto finalize() -> serialization_errors final {
        if(auto packed{
             _compressor.compress(done(), data_compression_level::normal)}) {
            return this->replace_with(packed);
        }
        return {serialization_error_code::backend_error};
    }
 
private:
    data_compressor _compressor{};
};
//------------------------------------------------------------------------------
} // namespace eagine
 
#endif // EAGINE_SERIALIZE_PACKED_BLOCK_SINK_HPP