cmsdk Namespace Reference

Classes
class	HTTPChunkedDecoder
class	SSEEventParser
class	StreamByteSource
class	ConnectionByteSource
class	EventStreamFrameParser

Enumerations
enum	StreamReadResult { SRC_DATA , SRC_AGAIN , SRC_CLOSED , SRC_ERROR }
enum	StreamPumpResult { PUMP_COMPLETE , PUMP_CLOSED , PUMP_ERROR , PUMP_LIMIT }

Functions
StreamPumpResult	pumpChunkedStream (StreamByteSource &src, HTTPChunkedDecoder &dec, const std::function< void(const char *, size_t)> &onData, size_t maxIterations=100000, size_t readSize=4096)
StreamPumpResult	pumpSSEStream (StreamByteSource &src, SSEEventParser &parser, const std::function< void(const std::string &)> &onEvent, size_t maxIterations=100000, size_t readSize=4096)
StreamPumpResult	pumpEventStream (StreamByteSource &src, EventStreamFrameParser &parser, const std::function< void(const EventStreamFrameParser::Frame &)> &onFrame, size_t maxIterations=100000, size_t readSize=4096)

Enumeration Type Documentation

StreamPumpResult

enum cmsdk::StreamPumpResult

Enumerator
PUMP_COMPLETE
PUMP_CLOSED
PUMP_ERROR
PUMP_LIMIT

Definition at line 245 of file StreamDecoders.h.

StreamReadResult

enum cmsdk::StreamReadResult

Enumerator
SRC_DATA
SRC_AGAIN
SRC_CLOSED
SRC_ERROR

Definition at line 207 of file StreamDecoders.h.

Function Documentation

pumpChunkedStream()

StreamPumpResult cmsdk::pumpChunkedStream ( StreamByteSource & src, HTTPChunkedDecoder & dec, const std::function< void(const char *, size_t)> & onData, size_t maxIterations = 100000, size_t readSize = 4096 )

inline

Definition at line 255 of file StreamDecoders.h.

References cmsdk::HTTPChunkedDecoder::body(), cmsdk::HTTPChunkedDecoder::feed(), cmsdk::HTTPChunkedDecoder::isComplete(), PUMP_CLOSED, PUMP_COMPLETE, PUMP_ERROR, PUMP_LIMIT, cmsdk::StreamByteSource::read(), SRC_CLOSED, SRC_DATA, and SRC_ERROR.

pumpEventStream()

StreamPumpResult cmsdk::pumpEventStream ( StreamByteSource & src, EventStreamFrameParser & parser, const std::function< void(const EventStreamFrameParser::Frame &)> & onFrame, size_t maxIterations = 100000, size_t readSize = 4096 )

inline

Definition at line 446 of file StreamDecoders.h.

References cmsdk::EventStreamFrameParser::feed(), cmsdk::EventStreamFrameParser::nextFrame(), PUMP_COMPLETE, PUMP_ERROR, PUMP_LIMIT, cmsdk::StreamByteSource::read(), SRC_CLOSED, SRC_DATA, and SRC_ERROR.

pumpSSEStream()

StreamPumpResult cmsdk::pumpSSEStream ( StreamByteSource & src, SSEEventParser & parser, const std::function< void(const std::string &)> & onEvent, size_t maxIterations = 100000, size_t readSize = 4096 )

inline

Definition at line 281 of file StreamDecoders.h.

References cmsdk::SSEEventParser::feed(), cmsdk::SSEEventParser::isDone(), cmsdk::SSEEventParser::nextEvent(), PUMP_CLOSED, PUMP_COMPLETE, PUMP_ERROR, PUMP_LIMIT, cmsdk::StreamByteSource::read(), SRC_CLOSED, SRC_DATA, and SRC_ERROR.