basic/
basic.rs

1use kumoko::{client::Client, server::Server};
2
3const IP: &str = "[::1]:50052";
4
5#[tokio::main]
6async fn main() {
7    let mut server = Server::<i32, i32>::bind(IP).await.unwrap();
8    let mut client = Client::connect(IP).await.unwrap();
9
10    client.emit_request(15).await;
11
12    let (req, origin) = server.get_request().await;
13    server.emit_response(req + 4, origin.into()).await;
14
15    let res: i32 = client.get_response().await.unwrap();
16
17    println!("OUTPUT: {}", res);
18}