Struct SideA 

pub struct SideA<Req, Resp> { /* private fields */ }

Side A endpoint (request sender, response receiver)

A 方的 channel 端点（请求发送方，响应接收方）

Implementations

impl<Req, Resp> SideA<Req, Resp>

pub async fn request(&self, req: Req) -> Result<Resp, ChannelError>

Send a request and wait for response

This method will:

1. Wait for channel to be idle (if previous request is still being processed)
2. Send request to side B
3. Wait for side B’s response
4. Return the response

发送请求并等待响应

这个方法会：

1. 等待 channel 进入空闲状态（如果之前的请求还在处理中）
2. 发送请求到 B 方
3. 等待 B 方的响应
4. 返回响应

Returns

• Ok(response): Received response from side B
• Err(ChannelError::Closed): Side B has been closed

Example

let (side_a, side_b) = channel::<String, i32>();
 
tokio::spawn(async move {
    while let Ok(guard) = side_b.recv_request().await {
        let response = guard.request().len() as i32;
        guard.reply(response);
    }
});
 
let response = side_a.request("Hello".to_string()).await;
assert_eq!(response, Ok(5));

Trait Implementations

impl<Req, Resp> Drop for SideA<Req, Resp>

fn drop(&mut self)

Executes the destructor for this type.