test.rs

use irpc::{
    channel::{mpsc, oneshot},
    rpc_requests,
};
use serde::{Deserialize, Serialize};

#[derive(Debug, Serialize, Deserialize)]
struct PutRequest {
    key: String,
    value: String,
}

#[derive(Debug, Serialize, Deserialize)]
struct GetRequest {
    key: String,
}

#[rpc_requests(TestMessage, alias = "Msg")]
#[derive(Debug, Serialize, Deserialize)]
enum TestProtocol {
    #[rpc(tx = oneshot::Sender<String>)]
    Put(PutRequest),
    #[rpc(tx = mpsc::Sender<String>)]
    Get(GetRequest),
}

fn foo(msg: PutMsg) -> String {
    // does not compile!
    format!(
        "Received Put request with key: {}, value: {}",
        msg.inner.key, msg.inner.value
    )
}