extends StaticBody


func _ready():
	var forks = get_tree().get_nodes_in_group("PipeForks")
	for f in forks:
		f.connect("flow_changed", self, "_update_pipe_colors")


func _update_pipe_colors():
	var pipes = get_tree().get_nodes_in_group("Pipes")
	for p in pipes:
		p.update_content_color()


func _on_Fork1_flow_changed():
	pass # Replace with function body.