net/quinn: Fix test using QUIC Stream

Part-of: <https://gitlab.freedesktop.org/gstreamer/gst-plugins-rs/-/merge_requests/1634>
This commit is contained in:
Sanchayan Maity 2024-11-13 21:25:44 +05:30 committed by GStreamer Marge Bot
parent 5bf44b6187
commit d5425c5225
2 changed files with 6 additions and 0 deletions

View file

@ -836,6 +836,9 @@ impl QuinnQuicSrc {
}
};
// TODO:
// Decide if the ordering matters when we might have a STREAM
// Close followed by a Connection Close almost immediately.
let mut tasks: FuturesUnordered<BoxFuture<QuinnFuture>> = FuturesUnordered::new();
tasks.push(Box::pin(datagram(connection.clone())));

View file

@ -44,6 +44,9 @@ fn test_send_receive_without_datagram() {
assert!(h1.push(make_buffer(content)) == Ok(gst::FlowSuccess::Ok));
// Wait a bit before sending Eos and shutting down the pipeline
thread::sleep(std::time::Duration::from_secs(2));
h1.push_event(gst::event::Eos::new());
h1.element().unwrap().set_state(gst::State::Null).unwrap();