(&self)
| 138 | |
| 139 | impl DynPorts<Receiver> { |
| 140 | pub fn try_fetch(&self) -> Option<(u64, Receiver)> { |
| 141 | for broker in self.brokers.values() { |
| 142 | if let Some(mut conns) = broker.try_fetch::<DynConns>() { |
| 143 | let conn = conns.outputs.remove(&self.target).unwrap_or_else(|| { |
| 144 | panic!("port {} not found in graph {}", self.target, broker.topic()) |
| 145 | }); |
| 146 | return Some((conns.name, conn)); |
| 147 | } |
| 148 | } |
| 149 | None |
| 150 | } |
| 151 | |
| 152 | pub async fn fetch(&self) -> Result<(u64, Receiver)> { |
| 153 | let fut: Vec<_> = self |
no test coverage detected