mirror of
https://codeberg.org/StreamGraph/StreamGraph.git
synced 2024-11-13 19:49:55 +01:00
remove connections more thoroughly on delete
This commit is contained in:
parent
2e701de286
commit
dfbb5f10cd
1 changed files with 5 additions and 3 deletions
|
@ -167,11 +167,13 @@ func remove_outgoing_connection(from_port: int, to_node: String, to_port: int) -
|
||||||
return
|
return
|
||||||
|
|
||||||
var ports: Array = connections.get(to_node, []) as Array
|
var ports: Array = connections.get(to_node, []) as Array
|
||||||
if ports.is_empty():
|
|
||||||
return
|
|
||||||
|
|
||||||
ports.erase(to_port)
|
ports.erase(to_port)
|
||||||
|
|
||||||
|
if ports.is_empty():
|
||||||
|
(outgoing_connections[from_port] as Dictionary).erase(to_node)
|
||||||
|
if (outgoing_connections[from_port] as Dictionary).is_empty():
|
||||||
|
outgoing_connections.erase(from_port)
|
||||||
|
|
||||||
outgoing_connection_removed.emit(from_port)
|
outgoing_connection_removed.emit(from_port)
|
||||||
|
|
||||||
|
|
||||||
|
|
Loading…
Reference in a new issue