Skip to main content

hydro_test/embedded/
echo_network.rs

1use hydro_lang::prelude::*;
2
3pub struct Sender {}
4pub struct Receiver {}
5
6pub fn echo_network<'a>(
7    receiver: &Process<'a, Receiver>,
8    input: Stream<String, Process<'a, Sender>>,
9) -> Stream<String, Process<'a, Receiver>> {
10    input
11        .send(receiver, TCP.fail_stop().bincode().name("messages"))
12        .map(q!(|s| s.to_uppercase()))
13}