MCPcopy Create free account
hub / github.com/KDE/labplot / read

Method read

src/backend/datasources/MQTTTopic.cpp:155–163  ·  view source on GitHub ↗

! *\brief Reads every message from the message puffer */

Source from the content-addressed store, hash-verified

153 *\brief Reads every message from the message puffer
154 */
155void MQTTTopic::read() {
156 while (!m_messagePuffer.isEmpty()) {
157 qDebug() << "Reading from topic " << m_topicName;
158 auto msg = m_messagePuffer.takeFirst();
159 BufferReader reader(msg.payload());
160 m_filter
161 ->readFromDevice(reader, AbstractFileFilter::ImportMode::Replace, AbstractFileFilter::ImportMode::Append, 0, -1, this->mqttClient()->keepNValues());
162 }
163}
164
165// ##############################################################################
166// ################## Serialization/Deserialization ###########################

Calls 4

mqttClientMethod · 0.95
readFromDeviceMethod · 0.80
isEmptyMethod · 0.45
keepNValuesMethod · 0.45