non_buffered_serialization_buffer_impl.h

Go to the documentation of this file.

/*
 * Copyright 2024 MusicScience37 (Kenta Kabashima)
 *
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 *
 *     http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */
#pragma once
 
#include <array>
#include <cstddef>  // IWYU pragma: keep
 
#include "msgpack_light/details/mutable_static_binary_view.h"
#include "msgpack_light/details/pack_in_big_endian.h"
#include "msgpack_light/details/total_size_of.h"  // IWYU pragma: keep
#include "msgpack_light/output_stream.h"
 
namespace msgpack_light::details {

class non_buffered_serialization_buffer_impl {
public:
    explicit non_buffered_serialization_buffer_impl(output_stream& stream)
        : stream_(stream) {}
 
    non_buffered_serialization_buffer_impl(
        const non_buffered_serialization_buffer_impl&) = delete;
    non_buffered_serialization_buffer_impl(
        non_buffered_serialization_buffer_impl&&) = delete;
    non_buffered_serialization_buffer_impl& operator=(
        const non_buffered_serialization_buffer_impl&) = delete;
    non_buffered_serialization_buffer_impl& operator=(
        non_buffered_serialization_buffer_impl&&) = delete;

    ~non_buffered_serialization_buffer_impl() noexcept { flush(); }

    void flush() {
        // No operation.
    }

    void write(const unsigned char* data, std::size_t size) {
        stream_.write(data, size);
    }

    void put(unsigned char data) { write(&data, 1U); }

    template <typename... T>
    void write_in_big_endian(T... values) {
        std::array<unsigned char, total_size_of<T...>> buffer{};
        pack_in_big_endian(
            mutable_static_binary_view<total_size_of<T...>>(buffer.data()),
            values...);
        write(buffer.data(), buffer.size());
    }
 
private:
    output_stream& stream_;
};
 
}  // namespace msgpack_light::details