diff options
author | metamuffin <metamuffin@disroot.org> | 2023-02-05 21:25:24 +0100 |
---|---|---|
committer | metamuffin <metamuffin@disroot.org> | 2023-02-05 21:25:24 +0100 |
commit | 6f4a9528e6d55b0f8a94b452948dd74cf85976b3 (patch) | |
tree | a844d2894208b994cc71b1660e7e1c845c4e1008 /client-native-rift/src/main.rs | |
parent | 2c6f4dc839a279b9d5c10d674489998b021908b8 (diff) | |
download | keks-meet-6f4a9528e6d55b0f8a94b452948dd74cf85976b3.tar keks-meet-6f4a9528e6d55b0f8a94b452948dd74cf85976b3.tar.bz2 keks-meet-6f4a9528e6d55b0f8a94b452948dd74cf85976b3.tar.zst |
set_buffered_amount_low_threshold doesnt behave
Diffstat (limited to 'client-native-rift/src/main.rs')
-rw-r--r-- | client-native-rift/src/main.rs | 5 |
1 files changed, 3 insertions, 2 deletions
diff --git a/client-native-rift/src/main.rs b/client-native-rift/src/main.rs index 6255fe7..201e91d 100644 --- a/client-native-rift/src/main.rs +++ b/client-native-rift/src/main.rs @@ -23,6 +23,7 @@ use std::{ atomic::{AtomicUsize, Ordering}, Arc, }, + time::Duration, }; use tokio::{ fs::{self, File}, @@ -307,8 +308,8 @@ impl LocalResource for FileSender { }) } { - channel.set_buffered_amount_low_threshold(1 << 20).await; let reader = reader.clone(); + let pos = pos.clone(); let channel2 = channel.clone(); channel .on_buffered_amount_low(box move || { @@ -344,8 +345,8 @@ impl LocalResource for FileSender { }) }) .await; + channel.set_buffered_amount_low_threshold(1).await; } - channel.on_error(box move |err| Box::pin(async move { error!("channel error: {err}") })) }) } |