diff options
| author | Teddy Wing | 2021-06-07 20:05:29 +0200 | 
|---|---|---|
| committer | Teddy Wing | 2021-06-07 20:05:29 +0200 | 
| commit | c2131f516b7ce72f47b3a69afa962c4ac869695e (patch) | |
| tree | 4140137fcef97c3a48652192f53b697b33c91892 /src | |
| parent | 23c3f885c34c15084b06b15a4a8b37f4013d39d9 (diff) | |
| download | reflectub-c2131f516b7ce72f47b3a69afa962c4ac869695e.tar.bz2 | |
main: Limit to 5 repos for thread debugging
Diffstat (limited to 'src')
| -rw-r--r-- | src/main.rs | 6 | 
1 files changed, 6 insertions, 0 deletions
| diff --git a/src/main.rs b/src/main.rs index 4812223..bf9b7fe 100644 --- a/src/main.rs +++ b/src/main.rs @@ -116,6 +116,7 @@ fn run() -> anyhow::Result<()> {      // let mut joins = futures::stream::FuturesUnordered::new();      let mut joins = Vec::with_capacity(repos.len()); +    let mut i = 0;      for repo in repos {          let db = db.clone();          let mirror_root = mirror_root.clone(); @@ -135,6 +136,11 @@ fn run() -> anyhow::Result<()> {          });          joins.push(join); + +        if i == 5 { +            break; +        } +        i += 1;      }      // executor::block_on(future::join_all(joins)); | 
