diff options
author | Trygve Laugstøl <trygvis@inamo.no> | 2017-09-01 13:59:25 +0200 |
---|---|---|
committer | Trygve Laugstøl <trygvis@inamo.no> | 2017-09-01 14:06:01 +0200 |
commit | 1f2c7aae9fdd39a478944ccda5c9e82d76ab5db6 (patch) | |
tree | 691f851318c60465dd5d4c837136e991026432ff /apps/mqtt-publish.cpp | |
parent | 3af4d83dfa190d8d95aefbf31ae0b1d85abe492a (diff) | |
download | ble-toys-1f2c7aae9fdd39a478944ccda5c9e82d76ab5db6.tar.gz ble-toys-1f2c7aae9fdd39a478944ccda5c9e82d76ab5db6.tar.bz2 ble-toys-1f2c7aae9fdd39a478944ccda5c9e82d76ab5db6.tar.xz ble-toys-1f2c7aae9fdd39a478944ccda5c9e82d76ab5db6.zip |
o Renaming SampleOutputStream to SampleConsumer.
o Some c++ style fixes.
Diffstat (limited to 'apps/mqtt-publish.cpp')
-rw-r--r-- | apps/mqtt-publish.cpp | 10 |
1 files changed, 5 insertions, 5 deletions
diff --git a/apps/mqtt-publish.cpp b/apps/mqtt-publish.cpp index 25e8ae9..1498b73 100644 --- a/apps/mqtt-publish.cpp +++ b/apps/mqtt-publish.cpp @@ -22,12 +22,12 @@ using namespace trygvis::sensor; using namespace trygvis::sensor::io; using namespace trygvis::mqtt_support; -class MqttSampleOutputStream : public SampleOutputStream { +class MqttSampleOutputStream : public SampleConsumer { public: MqttSampleOutputStream(const o<string> &client_id, bool clean_session, string host, unsigned int port, string topic_name, unsigned int keep_alive) - : SampleOutputStream(), + : SampleConsumer(), client(host, port, keep_alive, client_id, clean_session), topic_name(topic_name) { client.connect(); @@ -37,15 +37,15 @@ public: client.disconnect(); }; - void write(SampleRecord const &sample) override { + void onSample(SampleRecord const &sample) override { if (sample.empty()) { return; } // make a string of the sample auto buf = make_shared<stringstream>(); - KeyValueSampleOutputStream out(buf, sample.dict); - out.write(sample); + KeyValueWriterSampleConsumer out(buf, sample.dict); + out.onSample(sample); string s = buf->str(); cout << "sample: " << s; |