diff options
| author | metamuffin <metamuffin@disroot.org> | 2023-01-17 22:34:25 +0100 |
|---|---|---|
| committer | metamuffin <metamuffin@disroot.org> | 2023-01-17 22:34:25 +0100 |
| commit | 2fc81eee903efa1f6da77b9f58fd2179356dad9f (patch) | |
| tree | 6c047c05c636f366220ca34f3312ccc7fb91e85c /client-native-rift | |
| parent | f85d40d8c6cc2f3b58d1e0ea7f0382db88fffd4e (diff) | |
| parent | 67694f908f7fc76f78566e6f02d89db2d7a19c1d (diff) | |
| download | keks-meet-2fc81eee903efa1f6da77b9f58fd2179356dad9f.tar keks-meet-2fc81eee903efa1f6da77b9f58fd2179356dad9f.tar.bz2 keks-meet-2fc81eee903efa1f6da77b9f58fd2179356dad9f.tar.zst | |
merge
Diffstat (limited to 'client-native-rift')
| -rw-r--r-- | client-native-rift/src/main.rs | 38 |
1 files changed, 23 insertions, 15 deletions
diff --git a/client-native-rift/src/main.rs b/client-native-rift/src/main.rs index 5d0c7d6..45f720a 100644 --- a/client-native-rift/src/main.rs +++ b/client-native-rift/src/main.rs @@ -192,21 +192,29 @@ impl EventHandler for Handler { let writer = writer.clone(); let pos = pos.clone(); Box::pin(async move { - let pos = pos.fetch_add(mesg.data.len(), Ordering::Relaxed); - info!( - "recv {:?} ({} of {})", - mesg.data.len(), - humansize::format_size(pos, DECIMAL), - humansize::format_size(resource.size.unwrap_or(0), DECIMAL), - ); - writer - .write() - .await - .as_mut() - .unwrap() - .write_all(&mesg.data) - .await - .unwrap(); + // TODO + if mesg.is_string { + let s = String::from_utf8((&mesg.data).to_vec()).unwrap(); + if &s == "end" { + info!("EOF reached") + } + } else { + let pos = pos.fetch_add(mesg.data.len(), Ordering::Relaxed); + info!( + "recv {:?} ({} of {})", + mesg.data.len(), + humansize::format_size(pos, DECIMAL), + humansize::format_size(resource.size.unwrap_or(0), DECIMAL), + ); + writer + .write() + .await + .as_mut() + .unwrap() + .write_all(&mesg.data) + .await + .unwrap(); + } }) }) } |