(
mut info_subcriber: Receiver<Info>,
mut warning_subscriber: UnboundedReceiver<Warning>,
)
| 324 | |
| 325 | #[cfg(feature = "cbf")] |
| 326 | pub async fn trace_logger( |
| 327 | mut info_subcriber: Receiver<Info>, |
| 328 | mut warning_subscriber: UnboundedReceiver<Warning>, |
| 329 | ) { |
| 330 | loop { |
| 331 | tokio::select! { |
| 332 | info = info_subcriber.recv() => { |
| 333 | if let Some(info) = info { |
| 334 | tracing::info!("{info}") |
| 335 | } |
| 336 | } |
| 337 | warn = warning_subscriber.recv() => { |
| 338 | if let Some(warn) = warn { |
| 339 | tracing::warn!("{warn}") |
| 340 | } |
| 341 | } |
| 342 | } |
| 343 | } |
| 344 | } |
| 345 | |
| 346 | // Handle Kyoto Client sync |
| 347 | #[cfg(feature = "cbf")] |
no outgoing calls
no test coverage detected