autd3-rs 0.2.0

Core async client library for the AUTD3 phased-array kit.
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 tokio::sync::oneshot;

use crate::error::Error;
use crate::response::Response;

pub struct ResponseFuture {
    pub(super) rx: oneshot::Receiver<Result<Response, Error>>,
}

impl std::future::Future for ResponseFuture {
    type Output = Result<Response, Error>;

    fn poll(
        mut self: std::pin::Pin<&mut Self>,
        cx: &mut std::task::Context<'_>,
    ) -> std::task::Poll<Self::Output> {
        match std::pin::Pin::new(&mut self.rx).poll(cx) {
            std::task::Poll::Ready(Ok(inner)) => std::task::Poll::Ready(inner),
            std::task::Poll::Ready(Err(_)) => std::task::Poll::Ready(Err(Error::RtClosed)),
            std::task::Poll::Pending => std::task::Poll::Pending,
        }
    }
}