use streamcraft::{
elements::text::{stdoutlog::StdoutLog, texttestsrc::TextTestSrc},
pipeline::Pipeline,
};
fn main() {
let stdoutlog = StdoutLog::new();
let mut texttest = TextTestSrc::new();
texttest
.link_sink_element(stdoutlog)
.expect("Failed to add sink element");
let mut pipeline = Pipeline::new(texttest);
pipeline.init().expect("Failed to initalize pipeline");
for _ in 0..3 {
pipeline.iter().expect("Failed to iterate pipeline");
}
pipeline.de_init().expect("Failed to de-init pipeline");
}