Function gstreamer_loop

src-tauri/src/util.rs:39–65

(
    pipeline: gst::Pipeline,
    on_message: impl Fn(&gst::Message) -> bool,
)

}

pub fn gstreamer_loop(
    pipeline: gst::Pipeline,
    on_message: impl Fn(&gst::Message) -> bool,
) -> anyhow::Result<()> {
    use gst::prelude::*;

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

    let bus = pipeline.bus().unwrap();

    for message in bus.iter_timed(gst::ClockTime::NONE) {
        match message.view() {
            gst::MessageView::Eos(_) => break,
            gst::MessageView::Error(err) => anyhow::bail!(format!("{:?}", err)),
            _ => {}
        }

        let should_break = on_message(&message);
        if should_break {
            break;
        };
    }

    pipeline.set_state(gst::State::Null)?;

    Ok(())
}

pub fn replace_multiple_whitespace(input: &str) -> String {
    let mut result = String::new();