ResponseWriter.hpp

Go to the documentation of this file.

#pragma once
#include <orbit/http/HttpResponse.hpp>
#include <string_view>
#include <memory>
#include <orbit/http/json.hpp>
 
namespace network { class Proactor; }
namespace concurrency { class ThreadPool; }
 
namespace http {
 
class ResponseWriter {
public:
    virtual ~ResponseWriter() = default;
 
    using Interceptor = std::function<void(HttpResponse&)>;
    virtual void add_interceptor(Interceptor interceptor) = 0;
 
    virtual void set_header(const std::string& key, const std::string& value) = 0;
 
    virtual network::Proactor& proactor() = 0;
    
    virtual concurrency::ThreadPool& thread_pool() = 0;
 
    virtual void send(HttpResponse&& response) = 0;
 
    virtual void send_headers(HttpResponse& response) = 0;
 
    virtual void write_chunk(std::string_view chunk) = 0;
 
    virtual void end() = 0;
 
    virtual void send_sse_event(std::string_view data, std::string_view event = "", std::string_view id = "") = 0;
 
    virtual void upgrade_to_raw_stream(std::function<void(std::string_view)> on_data, std::function<void()> on_close) = 0;
    
    virtual void read_body_stream(std::function<void(std::string_view)> on_data, std::function<void()> on_end) = 0;
};
 
} // namespace http