(&self, topic_paths: &[TopicPath])
| 286 | |
| 287 | impl Downset for RedisFetchDownSet { |
| 288 | fn intersection(&self, topic_paths: &[TopicPath]) -> Result<HashSet<ExternalId>> { |
| 289 | self.redis.intersection(self, topic_paths) |
| 290 | } |
| 291 | |
| 292 | fn downset(&self, path: &TopicPath) -> HashSet<ExternalId> { |
| 293 | self.client.downset(path).collect::<HashSet<ExternalId>>() |
no test coverage detected