From 1177aa8aca93f9e65fa044baa9b295fe14c2fdf4 Mon Sep 17 00:00:00 2001
From: Kunihiko Toumura <kunihiko.toumura.yv@hitachi.com>
Date: Fri, 29 Nov 2019 16:59:58 +0900
Subject: [PATCH] new-style callback function (yaml node)

---
 .../@node-red/nodes/core/parsers/70-YAML.js    | 18 ++++++++++--------
 1 file changed, 10 insertions(+), 8 deletions(-)

diff --git a/packages/node_modules/@node-red/nodes/core/parsers/70-YAML.js b/packages/node_modules/@node-red/nodes/core/parsers/70-YAML.js
index 1a34fdd57..69a6bf444 100644
--- a/packages/node_modules/@node-red/nodes/core/parsers/70-YAML.js
+++ b/packages/node_modules/@node-red/nodes/core/parsers/70-YAML.js
@@ -6,33 +6,35 @@ module.exports = function(RED) {
         RED.nodes.createNode(this,n);
         this.property = n.property||"payload";
         var node = this;
-        this.on("input", function(msg) {
+        this.on("input", function(msg,send,done) {
             var value = RED.util.getMessageProperty(msg,node.property);
             if (value !== undefined) {
                 if (typeof value === "string") {
                     try {
                         value = yaml.load(value);
                         RED.util.setMessageProperty(msg,node.property,value);
-                        node.send(msg);
+                        send(msg);
+                        done();
                     }
-                    catch(e) { node.error(e.message,msg); }
+                    catch(e) { done(e.message); }
                 }
                 else if (typeof value === "object") {
                     if (!Buffer.isBuffer(value)) {
                         try {
                             value = yaml.dump(value);
                             RED.util.setMessageProperty(msg,node.property,value);
-                            node.send(msg);
+                            send(msg);
+                            done();
                         }
                         catch(e) {
-                            node.error(RED._("yaml.errors.dropped-error"));
+                            done(RED._("yaml.errors.dropped-error"));
                         }
                     }
-                    else { node.warn(RED._("yaml.errors.dropped-object")); }
+                    else { node.warn(RED._("yaml.errors.dropped-object")); done(); }
                 }
-                else { node.warn(RED._("yaml.errors.dropped")); }
+                else { node.warn(RED._("yaml.errors.dropped")); done(); }
             }
-            else { node.send(msg); } // If no payload - just pass it on.
+            else { send(msg); done(); } // If no payload - just pass it on.
         });
     }
     RED.nodes.registerType("yaml",YAMLNode);