updated #27

cyberway · Jul 10, 2019 · e2310ba · e2310ba
1 parent a55779b
commit e2310ba
Showing 1 changed file with 5 additions and 2 deletions.
diff --git a/notifier.cpp b/notifier.cpp
@@ -83,15 +83,18 @@ int main(int argc, char** argv) {
     natsOptions_Destroy(opts);
     stanConnOptions_Destroy(connOpts);
 
+    bool is_warn = false;
     while (s == NATS_OK) {
         auto msg = std::make_unique<message>();
         static const auto start = "{\"msg_type\":\"";   // ok, it's ugly. TODO: ?parse json
         static const auto start_len = strlen(start);
         std::getline(std::cin, msg->data);
         if (done) {
             if (msg->data.size()) {
-                std::cerr << "WARNING! Pipe hasn't empty." << std::endl;
-                done = false;
+                if (!is_warn) {
+                    std::cerr << "WARNING! Pipe hasn't empty." << std::endl;
+                    is_warn = true;
+                }
             } else
                 break;
         }