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

..

Browse source
This commit is contained in:
sxyazi 2024-04-04 02:10:01 +08:00
parent c72adf883c
commit 4304bbc92f
No known key found for this signature in database
3 changed files with 3 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
yazi-dds/src/payload.rs
View file

@ -54,7 +54,7 @@ impl FromStr for Payload<'_> {
type Err = anyhow::Error; type Err = anyhow::Error;
fn from_str(s: &str) -> Result<Self, Self::Err> { fn from_str(s: &str) -> Result<Self, Self::Err> {
let mut parts = s.splitn(5, ','); let mut parts = s.splitn(4, ',');
let kind = parts.next().ok_or_else(|| anyhow!("empty kind"))?; let kind = parts.next().ok_or_else(|| anyhow!("empty kind"))?;

3
yazi-dds/src/server.rs
View file

@ -42,7 +42,7 @@ impl Server {
continue; continue;
} }
let mut parts = line.splitn(5, ','); let mut parts = line.splitn(4, ',');
let Some(id) = id else { continue }; let Some(id) = id else { continue };
let Some(kind) = parts.next() else { continue }; let Some(kind) = parts.next() else { continue };
let Some(receiver) = parts.next().and_then(|s| s.parse().ok()) else { continue }; let Some(receiver) = parts.next().and_then(|s| s.parse().ok()) else { continue };
@ -62,7 +62,6 @@ impl Server {
} }
if receiver == 0 && sender <= u16::MAX as u64 { if receiver == 0 && sender <= u16::MAX as u64 {
let Some(_) = parts.next() else { continue };
let Some(body) = parts.next() else { continue }; let Some(body) = parts.next() else { continue };
if !STATE.set(kind, sender as u16, body) { continue } if !STATE.set(kind, sender as u16, body) { continue }
} }

2
yazi-dds/src/state.rs
View file

@ -83,7 +83,7 @@ impl State {
let mut inner = HashMap::new(); let mut inner = HashMap::new();
while buf.read_line(&mut line).await? > 0 { while buf.read_line(&mut line).await? > 0 {
let mut parts = line.splitn(5, ','); let mut parts = line.splitn(4, ',');
let Some(kind) = parts.next() else { continue }; let Some(kind) = parts.next() else { continue };
let Some(_) = parts.next() else { continue }; let Some(_) = parts.next() else { continue };
let Some(severity) = parts.next().and_then(|s| s.parse::<u16>().ok()) else { continue }; let Some(severity) = parts.next().and_then(|s| s.parse::<u16>().ok()) else { continue };