aboutsummaryrefslogtreecommitdiff
path: root/stream/src/fragment.rs
diff options
context:
space:
mode:
Diffstat (limited to 'stream/src/fragment.rs')
-rw-r--r--stream/src/fragment.rs14
1 files changed, 11 insertions, 3 deletions
diff --git a/stream/src/fragment.rs b/stream/src/fragment.rs
index 2ce3c78..dfe101e 100644
--- a/stream/src/fragment.rs
+++ b/stream/src/fragment.rs
@@ -6,7 +6,7 @@
use crate::{stream_info, SMediaInfo};
use anyhow::{anyhow, bail, Result};
use jellybase::common::stream::StreamContainer;
-use jellyremuxer::matroska_to_mpeg4;
+use jellyremuxer::{matroska_to_mpeg4, matroska_to_webm::matroska_to_webm};
use jellytranscoder::fragment::transcode;
use log::warn;
use std::sync::Arc;
@@ -72,10 +72,18 @@ pub async fn fragment_stream(
},
)
.await?;
- eprintln!("{:?}", location.abs());
+
let mut frag = File::open(location.abs()).await?;
match container {
- StreamContainer::WebM => {}
+ StreamContainer::WebM => {
+ tokio::task::spawn_blocking(move || {
+ if let Err(err) =
+ matroska_to_webm(SyncIoBridge::new(frag), SyncIoBridge::new(b))
+ {
+ warn!("webm transmux failed: {err}");
+ }
+ });
+ }
StreamContainer::Matroska => {
tokio::task::spawn(async move {
if let Err(err) = tokio::io::copy(&mut frag, &mut b).await {