diff --git a/moq-sub/src/media.rs b/moq-sub/src/media.rs index 78f18c8b..2bcf8029 100644 --- a/moq-sub/src/media.rs +++ b/moq-sub/src/media.rs @@ -122,11 +122,9 @@ impl Media { if let TrackReaderMode::Groups(mut groups) = track.mode().await? { while let Some(group) = groups.next().await? { let out = out.clone(); - tokio::task::spawn(async move { - if let Err(err) = Self::recv_group(group, out).await { - warn!("failed to receive group: {err:?}"); - } - }); + if let Err(err) = Self::recv_group(group, out).await { + warn!("failed to receive group: {err:?}"); + } } } debug!("track {name}: finish"); @@ -140,7 +138,6 @@ impl Media { let out = out.clone(); let buf = Self::recv_object(object).await?; - // TODO: avoid interleaving out of order fragments out.lock().await.write_all(&buf).await?; }