| 143 | |
| 144 | impl Node for PyNode { |
| 145 | fn set_port(&mut self, port_name: &str, tag: Option<u64>, channel: &ChannelStorage) { |
| 146 | if let Some(port) = self.inputs.get_mut(port_name) { |
| 147 | let storage = &mut port.storage; |
| 148 | let id = tag.unwrap_or_else(|| storage.len() as u64); |
| 149 | storage.insert(id, Arc::new(channel.receiver())); |
| 150 | } else if let Some(port) = self.outputs.get_mut(port_name) { |
| 151 | let storage = &mut port.storage; |
| 152 | let id = tag.unwrap_or_else(|| storage.len() as u64); |
| 153 | storage.insert(id, Arc::new(channel.sender())); |
| 154 | } else { |
| 155 | unreachable!(); |
| 156 | } |
| 157 | } |
| 158 | fn set_port_dynamic(&mut self, _: &str, _: crate::node::DynPortsConfig) { |
| 159 | unimplemented!() |
| 160 | } |