ezsp 15.0.0

Ember ZNet Serial Protocol
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28

use std::num::NonZero;

use tokio::sync::mpsc::Sender;
use tokio::sync::oneshot;

use crate::Error;
use crate::api::message::Message;

pub trait NegotiateVersion {
    fn negotiate_version(
        &self,
        desired_version: NonZero<u8>,
    ) -> impl Future<Output = Result<(), Error>> + Send;
}

impl NegotiateVersion for Sender<Message> {
    async fn negotiate_version(&self, desired_version: NonZero<u8>) -> Result<(), Error> {
        let (response, rx) = oneshot::channel();

        self.send(Message::Connect {
            desired_version,
            response,
        })
        .await?;

        rx.await?
    }
}