mirror of https://github.com/node-red/node-red.git
Updated Design: Node Messaging API (markdown)
parent
1aa0ca7a15
commit
81900fdd24
|
@ -39,7 +39,7 @@ this.on('input', function(msg) {
|
|||
} else {
|
||||
node.error(err,msg);
|
||||
}
|
||||
node.complete(msg);
|
||||
node.done(null,msg);
|
||||
});
|
||||
```
|
||||
|
||||
|
@ -55,7 +55,7 @@ this.on('input', function(msg) {
|
|||
// do something with 'msg'
|
||||
if (!err) {
|
||||
node.send(msg);
|
||||
node.complete(msg);
|
||||
node.complete(msg, null, msg);
|
||||
} else {
|
||||
// Log the error, but don't provide the msg obj here
|
||||
node.error(err);
|
||||
|
@ -78,10 +78,15 @@ this.on('input', function(msg, send, done) {
|
|||
// do something with 'msg'
|
||||
if (!err) {
|
||||
send(msg);
|
||||
done();
|
||||
send(msg);
|
||||
send(msg);
|
||||
done(null, msg);
|
||||
} else {
|
||||
// Log the error, but don't provide the msg obj here
|
||||
done(err);
|
||||
node.error(error1);
|
||||
node.error(error2);
|
||||
node.error(error3);
|
||||
done(err, msg);
|
||||
}
|
||||
});
|
||||
```
|
||||
|
|
Loading…
Reference in New Issue