sse_parser.h

Go to the documentation of this file.

 
#pragma once
 
#include <neograph/api.h>
 
#include <string>
#include <string_view>
#include <vector>
 
namespace neograph::async {
 
struct SseEvent {
    std::string event;   
    std::string data;    
    std::string id;      
};
 
class NEOGRAPH_API SseEventParser {
public:
    void feed(std::string_view bytes);
 
    std::vector<SseEvent> drain();
 
    void reset() noexcept;
 
private:
    void   consume_line(std::string_view line);
    void   finish_event();
 
    std::string              raw_;              
    std::string              cur_data_;         
    std::string              cur_event_;        
    std::string              cur_id_;           
    bool                     cur_in_progress_ = false;
    std::vector<SseEvent>    pending_;
};
 
}  // namespace neograph::async