iwdrs 0.2.7

Rust crate for iwd
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
30
31
32
33
34
35
36

use futures_lite::{Stream, StreamExt, stream};
use zbus::Proxy;
use zvariant::OwnedValue;

pub mod access_point;
pub mod adapter;
pub mod agent;
pub mod daemon;
pub mod device;
pub mod error;
pub mod hidden_network;
mod iwd_interface;
pub mod known_network;
pub mod modes;
pub mod network;
pub mod session;
pub mod station;

async fn property_stream<T: TryFrom<OwnedValue, Error = zvariant::Error> + Unpin>(
    proxy: Proxy<'static>,
    initial_value: zbus::Result<T>,
    property_name: &'static str,
) -> zbus::Result<impl Stream<Item = zbus::Result<T>> + Unpin> {
    // `receive_property_changed` does not yield the initial value if another stream on the same property has already
    // been created and yielded a value. Therefore we manually add an initial value to the beginning of the stream
    // as most consumers will expect it to be there. Note that the first stream created for each property (per proxy)
    // will initially yield two elements, but I think that is a worthwhile tradeoff.
    Ok(Box::pin(
        stream::iter([initial_value]).chain(
            proxy
                .receive_property_changed(property_name)
                .await
                .then(|property_changed| async move { property_changed.get().await }),
        ),
    ))
}