如何在Gstreamer Rust中将udpsrc链接到rtpbin？

use gst::prelude::*;
use gst::ElementFactory;

let pipeline = gst::Pipeline::new(Some("my-pipeline"));

let udpsrc = ElementFactory::make("udpsrc", Some("my-udpsrc")).unwrap();
udpsrc.set_property("port", &5000).unwrap();

let rtpbin = ElementFactory::make("rtpbin", Some("my-rtpbin")).unwrap();

pipeline.add_many(&[&udpsrc, &rtpbin]).unwrap();

udpsrc.link(&rtpbin).unwrap();

pipeline.set_state(gst::State::Playing).unwrap();

use gst::prelude::*;
use gst::ElementFactory;

fn main() {
    // Initialize GStreamer
    gst::init().unwrap();

    // Create pipeline
    let pipeline = gst::Pipeline::new(Some("my-pipeline"));

    // Create udpsrc element
    let udpsrc = ElementFactory::make("udpsrc", Some("my-udpsrc")).unwrap();
    udpsrc.set_property("port", &5000).unwrap();

    // Create rtpbin element
    let rtpbin = ElementFactory::make("rtpbin", Some("my-rtpbin")).unwrap();

    // Add udpsrc and rtpbin to pipeline
    pipeline.add_many(&[&udpsrc, &rtpbin]).unwrap();

    // Link udpsrc and rtpbin
    udpsrc.link(&rtpbin).unwrap();

    // Start pipeline
    pipeline.set_state(gst::State::Playing).unwrap();

    // Wait until error or EOS
    let bus = pipeline.get_bus().unwrap();
    for msg in bus.iter_timed(gst::CLOCK_TIME_NONE) {
        use gst::MessageView;

        match msg.view() {
            MessageView::Error(err) => {
                println!(
                    "Error received from element {}: {}",
                    msg.get_src().get_path_string(),
                    err.get_error()
                );
                println!("Debugging information: {:?}", err.get_debug());
                break;
            }
            MessageView::Eos(..) => break,
            _ => (),
        }
    }

    // Stop pipeline
    pipeline.set_state(gst::State::Null).unwrap();
}