Struct SideA 

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

Side A endpoint (request sender, response receiver) - can be cloned

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. Push request to the queue
2. Wait for side B to process and respond
3. Return the response

发送请求并等待响应

这个方法会：

1. 将请求推入队列
2. 等待 B 方处理并响应
3. 返回响应

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 len = guard.request().len() as i32;
        guard.reply(len);
    }
});
 
let response = side_a.request("Hello".to_string()).await;
assert_eq!(response, Ok(5));

pub fn try_request( &self, req: Req, ) -> Result<impl Future<Output = Result<Resp, ChannelError>>, ChannelError>

Try to send a request without waiting for response

Returns a future that will resolve to the response.

尝试发送请求但不等待响应

返回一个 future，将解析为响应。

Trait Implementations

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

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

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

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

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

fn drop(&mut self)

Executes the destructor for this type.