adjust client reconnect: discarding incoming user messages, return if…

… the client itself is dead instead of hanging

src/client.rs

@@ -388,7 +388,22 @@ impl<E: ClientExt> ClientActor<E> {
         };
         tracing::info!("reconnecting in {}s", reconnect_interval.as_secs());
         for i in 1.. {
-            tokio::time::sleep(reconnect_interval).await;
+            // discard messages until either the reconnect interval passes or the socket receiver disconnects
+            let sleep = tokio::time::sleep(reconnect_interval);
+            tokio::pin!(sleep);
+            loop {
+                tokio::select! {
+                    _ = &mut sleep => break,
+                    Some(_) = self.to_socket_receiver.recv() => {
+                        tracing::warn!("client is reconnecting, discarding message from user");
+                        continue
+                    },
+                    else => {
+                        tracing::warn!("client is dead, aborting reconnect");
+                        return
+                    },
+                }
+            }
             tracing::info!("reconnecting attempt no: {}...", i);
             let connect_http_request = self.config.connect_http_request();
             let result = tokio_tungstenite::connect_async(connect_http_request).await;