summaryrefslogtreecommitdiff
path: root/client-native-rift/src
diff options
context:
space:
mode:
authormetamuffin <metamuffin@disroot.org>2023-02-05 21:25:24 +0100
committermetamuffin <metamuffin@disroot.org>2023-02-05 21:25:24 +0100
commit6f4a9528e6d55b0f8a94b452948dd74cf85976b3 (patch)
treea844d2894208b994cc71b1660e7e1c845c4e1008 /client-native-rift/src
parent2c6f4dc839a279b9d5c10d674489998b021908b8 (diff)
downloadkeks-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')
-rw-r--r--client-native-rift/src/main.rs5
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}") }))
})
}