Skip to main content

hydro_test/local/
singleton_input.rs

1use hydro_lang::prelude::*;
2
3pub fn prefix_names<'a>(
4    names: Stream<String, Process<'a, ()>>,
5    prefix: Singleton<String, Process<'a, ()>, Bounded>,
6) {
7    names
8        .cross_singleton(prefix)
9        .map(q!(|(name, prefix)| format!("{prefix} {name}")))
10        .embedded_output("output");
11}