Skip to content
Merged
Changes from all commits
Commits
Show all changes
28 commits
Select commit Hold shift + click to select a range
10dd1d7
fix(net): give an anonymous dial its own hop (#5025)
kixelated Oct 8, 2026
a97a13a
fix(rtmp): reassemble interleaved chunk streams independently (#4735)
kixelated Oct 3, 2026
6182551
test(net): adapt dial_split_horizon to release's test harness
kixelated Oct 9, 2026
1afd492
fix(js): drop a headless subgroup before FIRST_OBJECT (backport #5019)
kixelated Oct 9, 2026
64eee3d
fix(net): accept an End of Group status on a marked subgroup stream (…
kixelated Oct 9, 2026
952ecb7
fix(hang): accept AV1 profile 2 codec strings (#5064)
Jachm11 Oct 9, 2026
7711e52
fix(net): read each IETF uni stream's type in its own task (backport …
kixelated Oct 9, 2026
d073cc8
fix(moq-mux): configure H.265 from the SPS head when scuffle_h265 ref…
bgreenway Oct 8, 2026
8e3b232
fix(net): keep IETF subscriptions alive after a request FIN (backport…
kixelated Oct 9, 2026
dd88fa3
fix(transcode): refuse a fetch that starts mid-group (#4812)
kixelated Oct 5, 2026
65b6617
ci: the back-merge no longer enables auto-merge (backport #4619)
kixelated Oct 9, 2026
714e091
Merge pull request #5136 from moq-dev/backport/back-merge-land
kixelated Oct 10, 2026
71cdb96
Merge pull request #5120 from moq-dev/backport/js-headless-subgroup
kixelated Oct 10, 2026
873f75e
Merge pull request #5121 from moq-dev/backport/rtmp-chunk-reassembly
kixelated Oct 10, 2026
71eee73
Merge pull request #5122 from moq-dev/backport/av1-profile-2
kixelated Oct 10, 2026
ca2e1a8
Merge release into merge/release-into-main
moq-bot[bot] Oct 10, 2026
c771ce0
Merge pull request #5125 from moq-dev/backport/ietf-uni-dispatch
kixelated Oct 10, 2026
d4fc028
Merge release into merge/release-into-main
moq-bot[bot] Oct 10, 2026
d8812e2
Merge pull request #5129 from moq-dev/backport/h265-sps-head
kixelated Oct 10, 2026
39be75d
Merge release into merge/release-into-main
moq-bot[bot] Oct 10, 2026
9e51b53
Merge pull request #5134 from moq-dev/backport/transcode-fetch-group-…
kixelated Oct 10, 2026
d87cebf
Merge release into merge/release-into-main
moq-bot[bot] Oct 10, 2026
1df4155
Merge pull request #5127 from moq-dev/backport/end-of-group-status
kixelated Oct 10, 2026
75cb736
Merge release into merge/release-into-main
moq-bot[bot] Oct 10, 2026
ae8a3ab
Merge pull request #5133 from moq-dev/backport/ietf-fin-keeps-subscri…
kixelated Oct 10, 2026
f0d1a8e
Merge pull request #5126 from moq-dev/backport/anonymous-dial-hop
kixelated Oct 10, 2026
2c84a50
Merge release into merge/release-into-main
moq-bot[bot] Oct 10, 2026
94d177e
Merge origin/main into merge/release-into-main
kixelated Oct 10, 2026
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
33 changes: 33 additions & 0 deletions rs/moq-net/src/ietf/publisher.rs
Original file line number Diff line number Diff line change
Expand Up @@ -3827,6 +3827,39 @@ mod serve_tests {
}
}

/// A reset request stream still cancels the subscription on every draft.
#[moq_net_sim::test]
async fn requester_reset_cancels_subscriptions() {
for version in [
Version::Draft14,
Version::Draft15,
Version::Draft16,
Version::Draft17,
Version::Draft18,
Version::Draft19,
Version::Draft20,
Version::Draft21,
Version::Draft22,
] {
let h = serve(version);
let mut session = ScriptedSession::per_stream_reset(vec![vec![]]);
let mut stream = Stream::open(&mut session, version).await.unwrap();
let mut serving = TrackServe::new(
h.session.clone(),
h.track.subscribe(None),
RequestId(0),
version,
ServeRange::default(),
None,
);
let mut finished = false;
let run = h
.publisher
.run_subscription(&mut stream, &mut serving, &mut finished, async {});
assert!(futures::poll!(std::pin::pin!(run)).is_ready(), "{version}");
}
}

/// A close must count requests before their first poll and release them even
/// when a dispatched task is cancelled or its message is refused.
#[moq_net_sim::test]
Expand Down
Loading