Merge pull request #3121 from magma1447/dev

SPLIT Join node - support for msg.resetTimeout …
This commit is contained in:
Nick O'Leary
2021-09-30 10:45:42 +01:00
committed by GitHub
2 changed files with 14 additions and 1 deletions

View File

@@ -631,6 +631,19 @@ module.exports = function(RED) {
}
}
if (msg.hasOwnProperty("restartTimeout")) {
if (inflight[partId]) {
if (inflight[partId].timeout) {
clearTimeout(inflight[partId].timeout);
}
if (node.timer > 0) {
inflight[partId].timeout = setTimeout(function() {
completeSend(partId)
}, node.timer)
}
}
}
if (msg.hasOwnProperty("reset")) {
if (inflight[partId]) {
if (inflight[partId].timeout) {