commit 0f12987e190f46235c00e0bbed6df41fa29b3de2
parent 77bef8bb6bdcb6808a79e6e85ae54c6326b3fc7f
Author: n0tr1v <n0tr1v@protonmail.com>
Date: Fri, 7 Apr 2023 17:04:55 -0700
cleanup
Diffstat:
1 file changed, 4 insertions(+), 4 deletions(-)
diff --git a/src/main.rs b/src/main.rs
@@ -289,7 +289,7 @@ impl LeChatPHPClient {
fn start_keepalive_thread(
&self,
exit_rx: crossbeam_channel::Receiver<ExitSignal>,
- last_post_rx: crossbeam_channel::Receiver<bool>,
+ last_post_rx: crossbeam_channel::Receiver<()>,
) -> thread::JoinHandle<()> {
let tx = self.tx.clone();
let send_to = self.config.keepalive_send_to.clone();
@@ -314,7 +314,7 @@ impl LeChatPHPClient {
fn start_post_msg_thread(
&self,
exit_rx: crossbeam_channel::Receiver<ExitSignal>,
- last_post_tx: crossbeam_channel::Sender<bool>,
+ last_post_tx: crossbeam_channel::Sender<()>,
) -> thread::JoinHandle<()> {
let client = self.client.clone();
let rx = Arc::clone(&self.rx);
@@ -1204,7 +1204,7 @@ fn set_profile_base_info(
}
-fn post_msg(client: &Client, post_type_recv: PostType, full_url: &str, session: String, url: &str, last_post_tx: &crossbeam_channel::Sender<bool>) {
+fn post_msg(client: &Client, post_type_recv: PostType, full_url: &str, session: String, url: &str, last_post_tx: &crossbeam_channel::Sender<()>) {
let mut should_reset_keepalive_timer = false;
loop {
let post_type = post_type_recv.clone();
@@ -1372,7 +1372,7 @@ fn post_msg(client: &Client, post_type_recv: PostType, full_url: &str, session:
break;
}
if should_reset_keepalive_timer {
- last_post_tx.send(true).unwrap();
+ last_post_tx.send(()).unwrap();
}
}