From 1f2c7aae9fdd39a478944ccda5c9e82d76ab5db6 Mon Sep 17 00:00:00 2001
From: Trygve Laugstøl <trygvis@inamo.no>
Date: Fri, 1 Sep 2017 13:59:25 +0200
Subject: o Renaming SampleOutputStream to SampleConsumer. o Some c++ style
 fixes.

---
 apps/mqtt-publish.cpp | 10 +++++-----
 1 file changed, 5 insertions(+), 5 deletions(-)

(limited to 'apps/mqtt-publish.cpp')

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;
-- 
cgit v1.2.3