basws-client 0.1.0-dev-7

A simple async WebSocket client/server framework
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23

use crate::{client::Client, logic::ClientLogic};

#[derive(Clone)]
pub struct PendingResponse<T>
where
    T: ClientLogic,
{
    request_id: u64,
    client: Client<T>,
}

impl<T> PendingResponse<T>
where
    T: ClientLogic + 'static,
{
    pub(crate) fn new(request_id: u64, client: Client<T>) -> Self {
        Self { request_id, client }
    }

    pub async fn receive_response(&self) -> Result<Vec<T::Response>, async_channel::RecvError> {
        self.client.wait_for_response_to(self.request_id).await
    }
}