mirror of
https://github.com/node-red/node-red.git
synced 2023-10-10 13:36:53 +02:00
Handle uninitialised node in single-wire fastpath
This commit is contained in:
parent
f89ddb5f7a
commit
1153619a03
@ -92,6 +92,7 @@ function cloneMessage(msg) {
|
|||||||
|
|
||||||
Node.prototype.send = function(msg) {
|
Node.prototype.send = function(msg) {
|
||||||
var msgSent = false;
|
var msgSent = false;
|
||||||
|
var node;
|
||||||
|
|
||||||
if (msg === null || typeof msg === "undefined") {
|
if (msg === null || typeof msg === "undefined") {
|
||||||
return;
|
return;
|
||||||
@ -100,7 +101,10 @@ Node.prototype.send = function(msg) {
|
|||||||
// A single message and a single wire on output 0
|
// A single message and a single wire on output 0
|
||||||
// TODO: pre-load flows.get calls - cannot do in constructor
|
// TODO: pre-load flows.get calls - cannot do in constructor
|
||||||
// as not all nodes are defined at that point
|
// as not all nodes are defined at that point
|
||||||
flows.get(this._wire).receive(msg);
|
node = flows.get(this._wire);
|
||||||
|
if (node) {
|
||||||
|
node.receive(msg);
|
||||||
|
}
|
||||||
return;
|
return;
|
||||||
} else {
|
} else {
|
||||||
msg = [msg];
|
msg = [msg];
|
||||||
@ -122,7 +126,6 @@ Node.prototype.send = function(msg) {
|
|||||||
if (!util.isArray(msgs)) {
|
if (!util.isArray(msgs)) {
|
||||||
msgs = [msgs];
|
msgs = [msgs];
|
||||||
}
|
}
|
||||||
var node;
|
|
||||||
var k = 0;
|
var k = 0;
|
||||||
// for each recipent node of that output
|
// for each recipent node of that output
|
||||||
for (var j = 0; j < wires.length; j++) {
|
for (var j = 0; j < wires.length; j++) {
|
||||||
|
Loading…
Reference in New Issue
Block a user