<div dir="ltr">Hi, <div>I am building a pipeline for an rtsp stream where there will be video and an audio and data channel.</div><div>I connected the rtspsrc plugin to the stream and added a connect_pad_added signal.</div><div>I detect if the received pad is an audio channel and then I add the audio decoder and then add a connect_pad_added signal to it to receive the `src_pad` for it which is dynamic.</div><div> </div><div>For some reason the I receive the callback for the rtspsrc `connect_pad_added`, but I dont receive the callback that I connect the audio channel with.</div><div>Am I missing something?</div><div> </div><div>I appreciate any help with this.</div><div>Here is a code snippet.</div><div> </div><div>```</div><div><pre style="background-color:rgb(40,44,52);color:rgb(171,178,191);font-family:"JetBrains Mono",monospace;font-size:11.3pt">match gst::parse_launch(pipeline_str) { Ok(pipe_elem) => { set_pipeline_elem(Some(pipe_elem)); let media_info = get_probe_info(); { // the elem object is a pipeline element object created with parse_launch let pipeline = elem.downcast::<gst::Pipeline>().unwrap(); let rtspsrc = match pipeline.by_name("basesrc") { Some(rtspsrc) => rtspsrc, None => { log::error!("could not find audio_decoder"); return; } }; rtspsrc.connect_pad_added(move |src, src_pad| { let mut audio = false; match src_pad.current_caps() { Some(caps) => { let new_pad_struct = caps.structure(0).expect("Failed to get first structure of caps for audio"); for i in 0..new_pad_struct.n_fields() { match new_pad_struct.nth_field_name(i).unwrap() { "media" => { log::info!("media struct={:#?}", new_pad_struct); let media_type = new_pad_struct.value("media").unwrap(); let field_value = media_type.get::<&str>().unwrap(); audio = field_value.starts_with("audio"); break; } _ => {} } } } _ => {} } if !audio { return; } log::info!("it is an audio pad!!"); let decoder = ElementFactory::make("decodebin", None).unwrap(); pipeline.add(&decoder).unwrap(); src_pad.link(&decoder.static_pad("sink").unwrap()).unwrap(); log::info!("linked rtspsrc.audio->decoder.sink!!"); let pipeline_weak = pipeline.downgrade(); decoder.connect_pad_added(move |src, pad| { log::info!("recieved connect_pad added signal!!"); if pad.direction() == gst::PadDirection::Src { // received the src pad for the decoder!! log::info!("GUGURURURU received decoder pad from src!!!"); } }); });</pre></div></div>