diff options
| -rw-r--r-- | src/client.rs | 2 | ||||
| -rw-r--r-- | src/main.rs | 14 |
2 files changed, 6 insertions, 10 deletions
diff --git a/src/client.rs b/src/client.rs index 968e55f..7530880 100644 --- a/src/client.rs +++ b/src/client.rs | |||
| @@ -150,7 +150,7 @@ impl Connect for Client { | |||
| 150 | }) | 150 | }) |
| 151 | .collect(); | 151 | .collect(); |
| 152 | 152 | ||
| 153 | let relay_results = stream::iter(futures).buffer_unordered(5).collect().await; | 153 | let relay_results = stream::iter(futures).buffer_unordered(15).collect().await; |
| 154 | 154 | ||
| 155 | Ok(get_dedup_events(relay_results)) | 155 | Ok(get_dedup_events(relay_results)) |
| 156 | } | 156 | } |
diff --git a/src/main.rs b/src/main.rs index 996b697..85b2812 100644 --- a/src/main.rs +++ b/src/main.rs | |||
| @@ -48,14 +48,10 @@ enum Commands { | |||
| 48 | async fn main() -> Result<()> { | 48 | async fn main() -> Result<()> { |
| 49 | let cli = Cli::parse(); | 49 | let cli = Cli::parse(); |
| 50 | match &cli.command { | 50 | match &cli.command { |
| 51 | Commands::Login(args) => { | 51 | Commands::Login(args) => sub_commands::login::launch(&cli, args).await, |
| 52 | futures::executor::block_on(sub_commands::login::launch(&cli, args)) | 52 | Commands::Claim(args) => sub_commands::claim::launch(&cli, args).await, |
| 53 | } | 53 | Commands::Prs(args) => sub_commands::prs::launch(&cli, args).await, |
| 54 | Commands::Claim(args) => { | 54 | Commands::Pull => sub_commands::pull::launch().await, |
| 55 | futures::executor::block_on(sub_commands::claim::launch(&cli, args)) | 55 | Commands::Push => sub_commands::push::launch(&cli).await, |
| 56 | } | ||
| 57 | Commands::Prs(args) => futures::executor::block_on(sub_commands::prs::launch(&cli, args)), | ||
| 58 | Commands::Pull => futures::executor::block_on(sub_commands::pull::launch()), | ||
| 59 | Commands::Push => futures::executor::block_on(sub_commands::push::launch(&cli)), | ||
| 60 | } | 56 | } |
| 61 | } | 57 | } |