mroot/yazi
1
0
Fork 0
mirror of https://github.com/sxyazi/yazi.git synced 2026-07-25 08:41:05 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 3

fixup! feat: reconnect after a connection is lost

Browse source
This commit is contained in:
Mika Vilpas 2024-06-02 08:52:28 +03:00 • committed by sxyazi
parent 8b9ed5e39e
commit 2d3cd4d50e
No known key found for this signature in database
1 changed files with 0 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
yazi-dds/src/client.rs
View file

@ -69,14 +69,10 @@ impl Client {
/// If a server is closed, attempt to reconnect forever. /// If a server is closed, attempt to reconnect forever.
pub async fn echo_events_to_stdout(kinds: HashSet<String>) -> Result<()> { pub async fn echo_events_to_stdout(kinds: HashSet<String>) -> Result<()> {
let mut lines = Self::connect_listener(&kinds).await?; let mut lines = Self::connect_listener(&kinds).await?;
let mut msg_counter = 0;
loop { loop {
println!("Waiting for messages...");
match lines.next_line().await { match lines.next_line().await {
Ok(Some(s)) => { Ok(Some(s)) => {
println!("Received: message {} '{}'", msg_counter, s);
msg_counter += 1;
let kind = s.split(',').next(); let kind = s.split(',').next();
if matches!(kind, Some(kind) if kinds.contains(kind)) { if matches!(kind, Some(kind) if kinds.contains(kind)) {
println!("{}", s); println!("{}", s);
@ -87,11 +83,9 @@ impl Client {
match Self::connect_listener(&kinds).await { match Self::connect_listener(&kinds).await {
Ok(new_lines) => { Ok(new_lines) => {
lines = new_lines; lines = new_lines;
println!("Reconnected");
break; break;
} }
Err(_) => { Err(_) => {
println!("Reconnecting...");
time::sleep(time::Duration::from_secs(1)).await; time::sleep(time::Duration::from_secs(1)).await;
} }
}; };