chore: remove sleep steps

Signed-off-by: mikeee <[email protected]>

Author: mikeee

examples/actors/client.rs

@@ -12,10 +12,6 @@ pub struct MyRequest {
 
 #[tokio::main]
 async fn main() -> Result<(), Box<dyn std::error::Error>> {
-    // TODO: Handle this issue in the sdk
-    // Introduce delay so that dapr grpc port is assigned before app tries to connect
-    std::thread::sleep(std::time::Duration::new(2, 0));
-
     // Define the Dapr address
     let addr = "https://127.0.0.1".to_string();
 

examples/client/client.rs

@@ -1,9 +1,5 @@
 #[tokio::main]
 async fn main() -> Result<(), Box<dyn std::error::Error>> {
-    // TODO: Handle this issue in the sdk
-    // Introduce delay so that dapr grpc port is assigned before app tries to connect
-    std::thread::sleep(std::time::Duration::new(2, 0));
-
     // Set the Dapr address
     let addr = "https://127.0.0.1".to_string();
 

examples/configuration/main.rs

@@ -5,10 +5,6 @@ type DaprClient = dapr::Client<dapr::client::TonicClient>;
 
 #[tokio::main]
 async fn main() -> Result<(), Box<dyn std::error::Error>> {
-    // TODO: Handle this issue in the sdk
-    // Introduce delay so that dapr grpc port is assigned before app tries to connect
-    std::thread::sleep(std::time::Duration::new(2, 0));
-
     // Set the Dapr address
     let addr = "https://127.0.0.1".to_string();
 

examples/crypto/main.rs

@@ -7,7 +7,6 @@ use dapr::client::ReaderStream;
 
 #[tokio::main]
 async fn main() -> Result<(), Box<dyn std::error::Error>> {
-    sleep(std::time::Duration::new(2, 0)).await;
     let addr = "https://127.0.0.1".to_string();
 
     let mut client = dapr::Client::<dapr::client::TonicClient>::connect(addr).await?;

examples/invoke/grpc-proxying/client.rs

@@ -10,9 +10,6 @@ pub mod hello_world {
 
 #[tokio::main]
 async fn main() -> Result<(), Box<dyn std::error::Error>> {
-    // Sleep to allow for the server to become available
-    thread::sleep(Duration::from_secs(5));
-
     // Get the Dapr port and create a connection
     let port: u16 = std::env::var("DAPR_GRPC_PORT").unwrap().parse().unwrap();
     let address = format!("https://127.0.0.1:{}", port);

examples/invoke/grpc/client.rs

@@ -11,9 +11,6 @@ type DaprClient = dapr::Client<dapr::client::TonicClient>;
 
 #[tokio::main]
 async fn main() -> Result<(), Box<dyn std::error::Error>> {
-    // Sleep to allow for the server to become available
-    thread::sleep(Duration::from_secs(5));
-
     // Set the Dapr address
     let address = "https://127.0.0.1".to_string();
 

examples/pubsub/publisher.rs

@@ -17,10 +17,6 @@ struct Refund {
 
 #[tokio::main]
 async fn main() -> Result<(), Box<dyn std::error::Error>> {
-    // TODO: Handle this issue in the sdk
-    // Introduce delay so that dapr grpc port is assigned before app tries to connect
-    thread::sleep(Duration::from_secs(2));
-
     // Set address for Dapr connection
     let addr = "https://127.0.0.1".to_string();