Skip to main content

hydro_test/embedded/
o2m_broadcast.rs

1use hydro_lang::prelude::*;
2
3pub struct Src {}
4pub struct Dst {}
5
6pub fn o2m_broadcast<'a>(
7    cluster: &Cluster<'a, Dst>,
8    input: Stream<String, Process<'a, Src>>,
9) -> Stream<String, Cluster<'a, Dst>> {
10    input
11        .broadcast(
12            cluster,
13            TCP.fail_stop().bincode().name("o2m_data"),
14            nondet!(/** test */),
15        )
16        .map(q!(|s| s.to_uppercase()))
17}