// SPDX-License-Identifier: MIT use futures::stream::TryStreamExt; fn main() { let rt = tokio::runtime::Builder::new_current_thread() .enable_io() .build() .unwrap(); rt.block_on(get_interfaces()); } async fn get_interfaces() { let (connection, handle, _) = wl_nl80211::new_connection().unwrap(); tokio::spawn(connection); let mut interface_handle = handle.interface().get().execute().await; let mut msgs = Vec::new(); while let Some(msg) = interface_handle.try_next().await.unwrap() { msgs.push(msg); } assert!(!msgs.is_empty()); for msg in msgs { println!("{:?}", msg); } }