Class QueueStream

Defined in File thrift_stream_queue.hpp

Inheritance Relationships

Base Type

public network_bridge::Stream (Class Stream)

Class Documentation

class QueueStream : public network_bridge::Stream 

Public Functions

inline QueueStream()

inline virtual ~QueueStream()

inline bool is_shutdown() const

inline virtual int available()

inline void reset()

inline virtual void shutdown()

template<typename iterator> inline bool pushBytes(iterator begin, iterator end)

inline bool pushUint8(uint8_t v)

inline bool pushUint16(uint16_t v)

inline bool pushUint32(uint32_t v)

inline bool pushUint64(uint64_t v)

inline bool pushString(const std::string &v)

inline virtual bool readBytes(std::vector<uint8_t> &bytes, size_t len)

inline virtual size_t readSome(std::vector<uint8_t> &bytes, size_t maxlen)

Protected Functions

inline uint8_t getOneByte(std::unique_lock<std::mutex> &lock)

inline uint8_t getOneByte()

Protected Attributes

bool finish

std::mutex mtx

std::condition_variable q_condition

std::list<uint8_t> Q