diff --git a/sentinel/src/client.rs b/sentinel/src/client.rs
index 8f7bfd65..3a7b38c8 100644
--- a/sentinel/src/client.rs
+++ b/sentinel/src/client.rs
@@ -46,18 +46,20 @@ async fn run(mut receiver: mpsc::Receiver) {
&mut stream,
Input::Connected {
at: SystemTime::now(),
- version,
+ version: version.clone(),
},
)
.await;
while let Some(input) = receiver.recv().await {
- if send(&mut stream, input).await.is_err() {
- break;
+ match send(&mut stream, input).await {
+ Ok(()) => {}
+ Err(error) => {
+ log::warn!("Error sending message to sentinel server: {error}");
+ break;
+ }
}
}
-
- break;
}
Err(_) => {
time::sleep(time::Duration::from_secs(2)).await;
diff --git a/sentinel/src/lib.rs b/sentinel/src/lib.rs
index 24fdc3c0..49b2f1b9 100644
--- a/sentinel/src/lib.rs
+++ b/sentinel/src/lib.rs
@@ -75,7 +75,7 @@ pub fn run() -> impl Stream- {
},
State::Connected(stream) => match receive(stream).await {
Ok((stream, input)) => {
- let event = match dbg!(input) {
+ let event = match input {
Input::Connected { at, version } => {
Event::Connected { at, version }
}