(&self, git: &Arc<Client>, fetch: &F)
| 1241 | |
| 1242 | impl FetchActivity { |
| 1243 | pub fn call<F>(&self, git: &Arc<Client>, fetch: &F) -> Result<FetchActivityResult> |
| 1244 | where |
| 1245 | F: ActivityForPrefix, |
| 1246 | { |
| 1247 | let changes = match &self.path { |
| 1248 | Some((repo_id, id)) => git.fetch_activity(*repo_id, id, self.first)?, |
| 1249 | |
| 1250 | // Fetch the top-level activity feed from Redis rather than Git so as to avoid |
| 1251 | // write contention on a single file for every update. This could show up in the form |
| 1252 | // of merge conflicts when commits are being saved to Git. |
| 1253 | None => fetch.fetch_activity(RepoId::wiki(), self.first)?, |
| 1254 | }; |
| 1255 | |
| 1256 | Ok(FetchActivityResult { changes }) |
| 1257 | } |
| 1258 | } |
| 1259 | |
| 1260 | #[cfg(test)] |
nothing calls this directly
no test coverage detected