stream.hpp

Go to the documentation of this file.

#pragma once
 
#include <cstdint>
#include <string>
#include <vector>
 
#include "error.hpp"
 
namespace edjx {
 
namespace stream {
 
    class BaseStream {
    public:
        inline BaseStream() : initialized(false) {}
        inline BaseStream(uint32_t sd) : sd(sd), initialized(true) {}
 
        inline uint32_t get_sd() const {
            return sd;
        }
        bool is_initialized() const {
            return initialized;
        }
        edjx::error::StreamError close();
    protected:
        uint32_t sd;
        bool initialized;
    };
 
    class WriteStream : public BaseStream {
    public:
        inline WriteStream() {}
        inline WriteStream(uint32_t sd) : BaseStream(sd) {}
        edjx::error::StreamError write_chunk(const std::string & text);
        edjx::error::StreamError write_chunk(const std::vector<uint8_t> & bytes);
 
        edjx::error::StreamError abort();
    };
 
    class ReadStream : public BaseStream {
    public:
        inline ReadStream() {}
        inline ReadStream(uint32_t sd) : BaseStream(sd) {}
        edjx::error::StreamError read_chunk(std::vector<uint8_t> & result);
 
        edjx::error::StreamError pipe_to(WriteStream & write_stream);
 
        edjx::error::StreamError read_all(std::vector<uint8_t> & result);
    };
 
}}