Run the handler tasks too (#11)

Author: ivmarkov

Cargo.toml

@@ -14,7 +14,7 @@ rust-version = "1.77"
 
 [patch.crates-io]
 #rs-matter = { git = "https://github.com/project-chip/rs-matter" }
-rs-matter = { git = "https://github.com/ivmarkov/rs-matter", branch = "next" }
+rs-matter = { git = "https://github.com/ivmarkov/rs-matter", branch = "global-handler-access" }
 #rs-matter = { path = "../rs-matter/rs-matter" }
 #edge-nal = { git = "https://github.com/ivmarkov/edge-net" }
 #edge-nal-std = { git = "https://github.com/ivmarkov/edge-net" }

examples/light.rs

@@ -6,6 +6,7 @@
 //! If you want to use Ethernet, utilize `EthMatterStack` instead.
 //!
 //! The example implements a fictitious Light device (an On-Off Matter cluster).
+#![recursion_limit = "256"]
 
 use core::pin::pin;
 

examples/light_eth.rs

@@ -8,6 +8,7 @@
 //! its credentials etc. and can assume it "pre-exists".
 //!
 //! The example implements a fictitious Light device (an On-Off Matter cluster).
+#![recursion_limit = "256"]
 
 use core::pin::pin;
 

src/lib.rs

@@ -14,10 +14,11 @@ use core::net::{Ipv4Addr, Ipv6Addr, SocketAddr, SocketAddrV6};
 use core::pin::pin;
 
 use edge_nal::{UdpBind, UdpSplit};
-use embassy_futures::select::{select4, Either4};
+use embassy_futures::select::{select, select4, Either4};
 use embassy_sync::blocking_mutex::raw::NoopRawMutex;
 
 use persist::{KvBlobBuffer, KvBlobStore, MatterPersist, NetworkPersist};
+
 use rs_matter::dm::clusters::basic_info::BasicInfoConfig;
 use rs_matter::dm::clusters::dev_att::DevAttDataFetcher;
 use rs_matter::dm::clusters::gen_diag::NetifDiag;
@@ -31,6 +32,7 @@ use rs_matter::transport::network::{Address, ChainedNetwork, NetworkReceive, Net
 use rs_matter::utils::epoch::Epoch;
 use rs_matter::utils::init::{init, Init};
 use rs_matter::utils::rand::Rand;
+use rs_matter::utils::select::Coalesce;
 use rs_matter::utils::storage::pooled::PooledBuffers;
 use rs_matter::{BasicCommData, Matter, MATTER_PORT};
 
@@ -477,7 +479,9 @@ where
         // Reset the Matter transport buffers and all sessions first
         // self.matter().reset_transport()?;
 
-        self.run_responder(handler).await
+        select(self.run_responder(&handler), handler.run())
+            .coalesce()
+            .await
     }
 
     async fn run_psm<S, C>(&self, persist: &MatterPersist<'_, S, C>) -> Result<(), Error>