Searched defs:MQReader (Results 1 – 1 of 1) sorted by relevance
175 struct MQReader : public IReader { in doWrite() struct176 explicit MQReader(DataMQ &mq) : dataMQ(mq) {} in doWrite() function178 size_t operator()(void *dst, size_t sz) override { in doWrite()189 size_t totalRead = 0; in doWrite()190 DataMQ &dataMQ; in doWrite()