Refactor streaming_search_inner to return a Stream object

Cargo.toml

@@ -6,7 +6,7 @@ readme = "README.md"
 repository = "https://github.com/keaz/simple-ldap"
 keywords = ["ldap", "ldap3", "async", "high-level"]
 name = "simple-ldap"
-version = "1.6.1"
+version = "1.7.0"
 edition = "2021"
 
 

README.md

@@ -131,21 +131,33 @@ async fn main() -> Result<()> {
         };
 
     let pool = pool::build_connection_pool(&ldap_config).await;
-    let mut ldap = pool.pool.get_connection().await.unwrap();
-
-        let name_filter = EqFilter::from("cn".to_string(), "James".to_string());
-        let result = ldap
-            .streaming_search::<User>(
-                "ou=people,dc=example,dc=com",
-                self::ldap3::Scope::OneLevel,
-                &name_filter,
-                2,
-                vec!["cn", "sn", "uid"],
-            )
-            .await;
-        assert!(result.is_ok());
-        let result = result.unwrap();
-        assert!(result.len() == 2);
+    let ldap = pool.get_connection().await.unwrap();
+
+    let name_filter = EqFilter::from("cn".to_string(), "James".to_string());
+    let attra = vec!["cn", "sn", "uid"];
+    let result = ldap
+        .streaming_search(
+            "ou=people,dc=example,dc=com",
+            self::ldap3::Scope::OneLevel,
+            &name_filter,
+            2,
+            &attra,
+        )
+        .await;
+
+    let mut result = result.unwrap();
+    let mut count = 0;
+    loop {
+        match result.next::<User>().await {
+            Ok(StreamResult::Record(_)) => {
+                count += 1;
+            }
+            _ => {
+                break;
+            }
+        }
+    }
+    assert!(count == 2);
     Ok(ldap.unbind().await?)
 }
 ```