Impl new fn connects_with_name & use it in test_read_large_file_bug

Signed-off-by: Jiahao XU <[email protected]>

Author: NobodyXu

tests/openssh.rs

@@ -46,7 +46,7 @@ async fn session_builder_connect(mut builder: SessionBuilder, addr: &str) -> Vec
     sessions
 }
 
-async fn connects() -> Vec<Session> {
+async fn connects_with_name() -> Vec<(Session, &'static str)> {
     let mut sessions = Vec::with_capacity(2);
 
     let mut builder = SessionBuilder::default();
@@ -57,17 +57,25 @@ async fn connects() -> Vec<Session> {
 
     #[cfg(feature = "process-mux")]
     {
-        sessions.push(builder.connect(&addr()).await.unwrap());
+        sessions.push((builder.connect(&addr()).await.unwrap(), "process-mux"));
     }
 
     #[cfg(feature = "native-mux")]
     {
-        sessions.push(builder.connect_mux(&addr()).await.unwrap());
+        sessions.push((builder.connect_mux(&addr()).await.unwrap(), "native-mux"));
     }
 
     sessions
 }
 
+async fn connects() -> Vec<Session> {
+    connects_with_name()
+        .await
+        .into_iter()
+        .map(|(session, _name)| session)
+        .collect()
+}
+
 async fn connects_err(host: &str) -> Vec<Error> {
     session_builder_connects_err(host, SessionBuilder::default()).await
 }
@@ -940,7 +948,9 @@ async fn test_sftp_subsystem() {
 #[tokio::test]
 #[cfg_attr(not(ci), ignore)]
 async fn test_read_large_file_bug() {
-    for session in connects().await {
+    for (session, name) in connects_with_name().await {
+        eprintln!("Testing {name} implementation");
+
         let bs = 1024;
         let count = 20480;