Incorporated basic evaluation logic to play and test nodes
@@ -775,6 +775,36 @@ class BaseNode(NodeObject):
"""
return
+ def update_streams(self, *args):
+ """
+ Update all nodes joined by pipes to this.
+ """
+ nodes = []
+ trash = []
+
+ for port, nodeList in node.connected_output_nodes().items():
+ nodes.extend(nodeList)
+
+ while nodes:
+ node = nodes.pop()
+ if node not in trash:
+ trash.append(node)
+
+ for port, nodeList in node.connected_output_nodes().items():
+ nodes.extend(nodeList)
+
+ if not nodes:
+ try:
+ node.run()
+ except Exception as error:
+ print("Error Update Streams: %s" % str(error))
+
+ def run(self):
+ """
+ Node evaluation logics.
+ """
+ return
+
class BackdropNode(NodeObject):
"""
