upleb.uk

Public git repos — served from a NIP-34 GRASP relay at git.upleb.uk

summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
-rw-r--r--src/client.rs2
-rw-r--r--src/main.rs14
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 {
48async fn main() -> Result<()> { 48async 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}