Skip to main content

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}