hydro_test/embedded/m2o_send.rs
1use hydro_lang::live_collections::stream::NoOrder;
2use hydro_lang::location::MemberId;
3use hydro_lang::prelude::*;
4
5pub struct Src {}
6pub struct Dst {}
7
8pub fn m2o_send<'a>(
9 process: &Process<'a, Dst>,
10 input: Stream<String, Cluster<'a, Src>>,
11) -> Stream<(MemberId<Src>, String), Process<'a, Dst>, Unbounded, NoOrder> {
12 input
13 .send(process, TCP.fail_stop().bincode().name("m2o_data"))
14 .map(q!(|s| s.to_uppercase()))
15 .entries()
16}