refactor(publisher): ensure blocking telemetry tasks executes in a de…

…dicated thread for blocking tasks

crates/fuel-streams-publisher/src/telemetry/mod.rs

@@ -71,9 +71,7 @@ impl Telemetry {
             tracing::info!("Elastic logger pinged successfully!");
         };
 
-        self.runtime.start();
-
-        self.runtime.spawn(async move {
+        self.runtime.start(move || {
             system.write().refresh();
         });
 

crates/fuel-streams-publisher/src/telemetry/runtime.rs

@@ -40,7 +40,10 @@ impl Runtime {
         queue.push_back(Box::pin(task));
     }
 
-    pub fn start(&self) {
+    pub fn start<F>(&self, blocking_task_executor: F)
+    where
+        F: FnOnce() + Send + 'static + Clone,
+    {
         let interval = self.interval;
         let task_queue = Arc::clone(&self.task_queue);
 
@@ -51,6 +54,8 @@ impl Runtime {
                 // Wait for the interval
                 ticker.tick().await;
 
+                tokio::task::spawn_blocking(blocking_task_executor.clone());
+
                 // Lock the queue, drain tasks, and run them sequentially
                 let tasks: Vec<_> = {
                     let mut queue = task_queue.lock().unwrap();