fix bug

turulix · Oct 10, 2023 · c8812e9 · c8812e9
1 parent b51742a
commit c8812e9
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/memphis/src/memphis_client.rs b/memphis/src/memphis_client.rs
@@ -5,7 +5,7 @@ use async_nats::connection::State;
 use async_nats::jetstream::Context;
 use async_nats::{jetstream, Client, ConnectError, ConnectOptions, Event, Message};
 use bytes::Bytes;
-use log::info;
+use log::{error, info};
 use serde::Serialize;
 use uuid::Uuid;
 
@@ -96,6 +96,10 @@ impl MemphisClient {
             }
         };
 
+        while connection.connection_state() == State::Pending {
+            tokio::time::sleep(Duration::from_millis(50)).await;
+        }
+
         Ok(MemphisClient {
             jetstream_context: Arc::new(jetstream::new(connection.clone())),
             broker_connection: Arc::new(connection),