feat(providers): spawn task for listening to stream in ws

examples/providers/examples/ws.rs

@@ -25,5 +25,13 @@ async fn main() -> Result<()> {
         println!("{:?}", block.header.number);
     }
 
+    let handle = tokio::spawn(async move {
+        while let Some(block) = stream.next().await {
+            println!("{:?}", block.header.number);
+        }
+    });
+
+    handle.await?;
+
     Ok(())
 }

examples/providers/examples/ws_with_auth.rs

@@ -34,13 +34,22 @@ async fn main() -> Result<()> {
 
     println!("Awaiting blocks...");
 
-    while let Some(block) = stream_basic.next().await {
-        println!("From basic {:?}", block.header.number);
-    }
-
-    while let Some(block) = stream_bearer.next().await {
-        println!("From bearer {:?}", block.header.number);
-    }
+    // Spawning the block processing for basic auth as a new task
+    let basic_handle = tokio::spawn(async move {
+        while let Some(block) = stream_basic.next().await {
+            println!("From basic {:?}", block.header.number);
+        }
+    });
+
+    // Similarly for bearer auth
+    let bearer_handle = tokio::spawn(async move {
+        while let Some(block) = stream_bearer.next().await {
+            println!("From bearer {:?}", block.header.number);
+        }
+    });
+
+    // Wait for both tasks to complete
+    let _ = tokio::try_join!(basic_handle, bearer_handle)?;
 
     Ok(())
 }