frodovdr/node-red
1
0
Fork 0
mirror of https://github.com/node-red/node-red.git synced 2025-03-01 10:36:34 +00:00
Code Issues Packages Projects Releases Wiki Activity

do add to queue in case it needs to also be flushed

Browse Source
This commit is contained in:
Dave Conway-Jones 2024-10-31 17:21:53 +00:00
parent 33a5b2527c
commit d3219f0600
No known key found for this signature in database
GPG Key ID: 1DDB0E91A28C2643
1 changed files with 8 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
packages/node_modules/@node-red/nodes/core/function/89-delay.js vendored
View File

@ -253,11 +253,15 @@ module.exports = function(RED) {
if (node.allowrate && m.hasOwnProperty("rate") && !isNaN(parseFloat(m.rate))) { if (node.allowrate && m.hasOwnProperty("rate") && !isNaN(parseFloat(m.rate))) {
node.rate = m.rate; node.rate = m.rate;
} }
if (!msg.hasOwnProperty("reset")) { if (msg.hasOwnProperty("reset")) {
send(m); if (msg.hasOwnProperty("flush")) {
node.reportDepth(); node.buffer.push({msg: m, send: send, done: done});
node.intervalID = setInterval(sendMsgFromBuffer, node.rate); }
} }
else { send(m); }
node.reportDepth();
node.intervalID = setInterval(sendMsgFromBuffer, node.rate);
done(); done();
} }
} }