outputStream.h

Go to the documentation of this file.

 
#ifndef MAXOS_COMMON_OUTPUTSTREAM_H
#define MAXOS_COMMON_OUTPUTSTREAM_H
 
#include <cstdint>
#include <common/inputStream.h>
#include <common/string.h>
 
 
namespace MaxOS::common {
 
    template<class Type> class GenericOutputStream : public InputStreamProcessor<Type, Type> {
        public:
            GenericOutputStream();
            ~GenericOutputStream();
 
            void on_stream_read(Type) override;
            void on_end_of_stream(GenericInputStream<Type>*) override;
 
            virtual void write(Type);
            virtual void close();
 
            virtual GenericOutputStream<Type>& operator <<(Type);
    };
 
    class OutputStream : public GenericOutputStream<string> {
 
        public:
            OutputStream();
            ~OutputStream();
 
            virtual void line_feed();
            virtual void carriage_return();
            virtual void clear();
 
            void write(string string_to_write) override;
            void write(const char* string_to_write);
            virtual void write_char(char char_to_write);
            virtual void write_int(int int_to_write);
            virtual void write_hex(uint64_t hex_to_write);
 
            OutputStream& operator <<(string string_to_write) override;
            OutputStream& operator <<(const char* string_to_write);
            OutputStream& operator <<(int int_to_write);
            OutputStream& operator <<(uint64_t hex_to_write);
            OutputStream& operator <<(char char_to_write);
    };
 
 
 
 
    template<class Type> GenericOutputStream<Type>::GenericOutputStream() = default;
 
    template<class Type> GenericOutputStream<Type>::~GenericOutputStream() = default;
 
    template<class Type> void GenericOutputStream<Type>::on_stream_read(Type read_element) {
 
        // When something is read from the input stream, it is written to the output stream.
        write(read_element);
 
        // Pass the element to any handlers
        for(auto& input_stream_event_handler : this->m_input_stream_event_handlers)
            input_stream_event_handler->on_stream_read(read_element);
 
 
    }
 
    template<class Type> void GenericOutputStream<Type>::on_end_of_stream(GenericInputStream<Type>* stream) {
 
        // Close the stream.
        close();
 
        // Pass the event to any handlers
        for(auto& input_stream_event_handler : this->m_input_stream_event_handlers)
            input_stream_event_handler->on_end_of_stream(stream);
 
        // Remove the stream from the list of streams.
        InputStreamProcessor<Type, Type>::on_end_of_stream(stream);
 
    }
 
    template<class Type> void GenericOutputStream<Type>::write(Type) {
 
    }
 
    template<class Type> void GenericOutputStream<Type>::close() {
 
    }
 
    template<class Type> GenericOutputStream<Type>& GenericOutputStream<Type>::operator <<(Type write_element) {
 
        // write the element to the stream.
        write(write_element);
 
        // Return the stream.
        return *this;
    }
}
 
#endif //MAXOS_COMMON_OUTPUTSTREAM_H