ezsp 12.1.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
29

use tokio::sync::mpsc::Receiver;

use crate::Callback;
use crate::ember::Status;
use crate::frame::parameters::networking::handler::Handler as Networking;

pub trait AwaitEvent {
    fn await_network_status(&mut self, status: Status) -> impl Future<Output = ()> + Send;

    fn await_network_up(&mut self) -> impl Future<Output = ()> + Send {
        self.await_network_status(Status::NetworkUp)
    }

    fn await_network_down(&mut self) -> impl Future<Output = ()> + Send {
        self.await_network_status(Status::NetworkDown)
    }
}

impl AwaitEvent for Receiver<Callback> {
    async fn await_network_status(&mut self, status: Status) {
        while let Some(callback) = self.recv().await {
            if let Callback::Networking(Networking::StackStatus(stack_status)) = callback
                && stack_status.result() == Ok(status)
            {
                return;
            }
        }
    }
}