We want to see changes

This commit is contained in:
Maxime Augier 2024-04-20 09:23:24 +02:00
parent 96100bbe0a
commit e166866bb0

View File

@ -108,6 +108,6 @@ async fn extract(adapter: Arc<Adapter>, evt: AdapterEvent) -> Option<Data> {
} }
async fn sensor_reports<'a>(adapter: Arc<Adapter>) -> Result<impl Stream<Item=Data> + 'a> { async fn sensor_reports<'a>(adapter: Arc<Adapter>) -> Result<impl Stream<Item=Data> + 'a> {
Ok(adapter.discover_devices().await? Ok(adapter.discover_devices_with_changes().await?
.filter_map(move |evt| { extract(Arc::clone(&adapter), evt) })) .filter_map(move |evt| { extract(Arc::clone(&adapter), evt) }))
} }