wip4

zebrad/src/commands/connect.rs

@@ -124,14 +124,25 @@ impl ConnectCmd {
         info!("waiting for peer_set ready");
         peer_set.ready().await.map_err(Error::from_boxed_compat)?;
 
-        let addrs = match client.call(Request::GetPeers).await? {
-            Response::Peers(addrs) => addrs,
-            _ => bail!("Got wrong response type"),
-        };
-        info!(
-            addrs.len = addrs.len(),
-            "got addresses from peerset connected peer"
-        );
+        info!("peer_set became ready, constructing addr requests");
+
+        let mut addr_reqs = FuturesUnordered::new();
+        for i in 0..10usize {
+            info!(i, "awaiting peer_set ready");
+            peer_set.ready().await.map_err(Error::from_boxed_compat)?;
+            info!(i, "calling peer_set");
+            addr_reqs.push(peer_set.call(Request::GetPeers));
+        }
+
+        let mut all_addrs = Vec::new();
+        while let Some(Ok(Response::Peers(addrs))) = addr_reqs.next().await {
+            info!(
+                all_addrs.len = all_addrs.len(),
+                addrs.len = addrs.len(),
+                "got address response"
+            );
+            all_addrs.extend(addrs);
+        }
 
         loop {
             // empty loop ensures we don't exit the application,