(&mut self)
| 156 | type Item = Result<SerializedGraphEdge, PristineError>; |
| 157 | |
| 158 | fn next(&mut self) -> Option<Self::Item> { |
| 159 | loop { |
| 160 | match self.inner.next() { |
| 161 | Some(Ok(edge)) => { |
| 162 | let introduced_by = edge.introduced_by(); |
| 163 | if introduced_by == NodeId::ROOT || self.visible.contains(&introduced_by) { |
| 164 | return Some(Ok(edge)); |
| 165 | } |
| 166 | // Skip edges not visible in this view |
| 167 | continue; |
| 168 | } |
| 169 | Some(Err(e)) => return Some(Err(e)), |
| 170 | None => return None, |
| 171 | } |
| 172 | } |
| 173 | } |
| 174 | } |
| 175 | |
| 176 | impl<'a, T: GraphTxnT> GraphTxnT for ViewGraph<'a, T> { |
no test coverage detected