diff options
| author | metamuffin <metamuffin@disroot.org> | 2023-10-02 14:07:30 +0200 |
|---|---|---|
| committer | metamuffin <metamuffin@disroot.org> | 2023-10-02 14:07:30 +0200 |
| commit | 68a0ae056905375d997979d3ca327966d4242697 (patch) | |
| tree | d0f5037cb956ad22b183a31702b365513c100873 /stream/src/segment.rs | |
| parent | a7513d5f0db18570cc7db405810ce66cab6475e4 (diff) | |
| download | jellything-68a0ae056905375d997979d3ca327966d4242697.tar jellything-68a0ae056905375d997979d3ca327966d4242697.tar.bz2 jellything-68a0ae056905375d997979d3ca327966d4242697.tar.zst | |
segment transcoding
Diffstat (limited to 'stream/src/segment.rs')
| -rw-r--r-- | stream/src/segment.rs | 6 |
1 files changed, 5 insertions, 1 deletions
diff --git a/stream/src/segment.rs b/stream/src/segment.rs index 02f3100..08d3efa 100644 --- a/stream/src/segment.rs +++ b/stream/src/segment.rs @@ -50,7 +50,11 @@ pub async fn segment_stream( ) .await?; let mut output = File::open(location.path()).await?; - tokio::io::copy(&mut output, &mut b).await?; + tokio::task::spawn(async move { + if let Err(err) = tokio::io::copy(&mut output, &mut b).await { + warn!("cannot write stream: {err}") + } + }); } else { let b = SyncIoBridge::new(b); tokio::task::spawn_blocking(move || { |