diff options
author | metamuffin <metamuffin@disroot.org> | 2023-04-04 11:15:03 +0200 |
---|---|---|
committer | metamuffin <metamuffin@disroot.org> | 2023-04-04 11:15:03 +0200 |
commit | 99d1ab55dfb1714d8f574060e618dc93c94f245c (patch) | |
tree | b01f6ccb6b4060f120a71145fbbded0131c9430e /client-native-rift/src | |
parent | 84587df365c61297e08d00f28317b452681a4b84 (diff) | |
parent | fe36a0640f2e36baad1f08033f09b49bdd0f1062 (diff) | |
download | keks-meet-99d1ab55dfb1714d8f574060e618dc93c94f245c.tar keks-meet-99d1ab55dfb1714d8f574060e618dc93c94f245c.tar.bz2 keks-meet-99d1ab55dfb1714d8f574060e618dc93c94f245c.tar.zst |
Merge branch 'master' of codeberg.org:metamuffin/keks-meet
Diffstat (limited to 'client-native-rift/src')
-rw-r--r-- | client-native-rift/src/main.rs | 46 |
1 files changed, 18 insertions, 28 deletions
diff --git a/client-native-rift/src/main.rs b/client-native-rift/src/main.rs index 45f720a..1f10b83 100644 --- a/client-native-rift/src/main.rs +++ b/client-native-rift/src/main.rs @@ -167,8 +167,7 @@ impl EventHandler for Handler { info!("channel opened"); *writer.write().await = Some(s.args.action.create_writer().await) }) - }) - .await; + }); } { let writer = writer.clone(); @@ -183,8 +182,7 @@ impl EventHandler for Handler { exit(0); } }) - }) - .await; + }); } { let writer = writer.clone(); @@ -218,13 +216,11 @@ impl EventHandler for Handler { }) }) } - .await; dc.on_error(box move |err| { Box::pin(async move { error!("data channel errored: {err}"); }) - }) - .await; + }); } } }) @@ -292,31 +288,27 @@ impl LocalResource for FileSender { { let reader = reader.clone(); let reader_factory = reader_factory.clone(); - channel - .on_open(box move || { - let reader = reader.clone(); - Box::pin(async move { - info!("channel open"); - *reader.write().await = Some(reader_factory.create_reader().await); - }) + channel.on_open(box move || { + let reader = reader.clone(); + Box::pin(async move { + info!("channel open"); + *reader.write().await = Some(reader_factory.create_reader().await); }) - .await; + }) } { let reader = reader.clone(); - channel - .on_close(box move || { - let reader = reader.clone(); - Box::pin(async move { - info!("channel closed"); - *reader.write().await = None; - }) + channel.on_close(box move || { + let reader = reader.clone(); + Box::pin(async move { + info!("channel closed"); + *reader.write().await = None; }) - .await; + }) } { - 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 || { @@ -352,11 +344,9 @@ 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}") })) - .await; + channel.on_error(box move |err| Box::pin(async move { error!("channel error: {err}") })) }) } } |