cvedia::rt::SseEventBuffer

Public Functions

	Name
	SseEventBuffer(size_t count =MaxEvents, size_t bytes =MaxBytes, size_t messageBytes =MaxMessageBytes)
bool	feed(char const * data, size_t length)
void	resetParser()
std::string	drain(size_t maxEvents =BatchEvents, size_t maxBytes =BatchBytes)
auto const &	statistics() const
uint64_t	malformedMessages() const
uint64_t	oversizedMessages() const

Public Attributes

	Name
constexpr size_t	MaxEvents
constexpr size_t	MaxBytes
constexpr size_t	MaxMessageBytes
constexpr size_t	BatchEvents
constexpr size_t	BatchBytes

Public Functions Documentation

function SseEventBuffer

inline explicit SseEventBuffer(
    size_t count =MaxEvents,
    size_t bytes =MaxBytes,
    size_t messageBytes =MaxMessageBytes
)

function feed

inline bool feed(
    char const * data,
    size_t length
)

function resetParser

inline void resetParser()

function drain

inline std::string drain(
    size_t maxEvents =BatchEvents,
    size_t maxBytes =BatchBytes
)

function statistics

inline auto const & statistics() const

function malformedMessages

inline uint64_t malformedMessages() const

function oversizedMessages

inline uint64_t oversizedMessages() const

Public Attributes Documentation

variable MaxEvents

static constexpr size_t MaxEvents = 4096;

variable MaxBytes

static constexpr size_t MaxBytes = 64 * 1024 * 1024;

variable MaxMessageBytes

static constexpr size_t MaxMessageBytes = 32 * 1024 * 1024;

variable BatchEvents

static constexpr size_t BatchEvents = 256;

variable BatchBytes

static constexpr size_t BatchBytes = 4 * 1024 * 1024;

---