aboutsummaryrefslogtreecommitdiff
path: root/stream/src
diff options
context:
space:
mode:
Diffstat (limited to 'stream/src')
-rw-r--r--stream/src/segment.rs6
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 || {