(
application_id: Uuid,
vars: &HashMap<String, String>,
pl: &integration::TxAckEvent,
)
| 312 | } |
| 313 | |
| 314 | pub async fn txack_event( |
| 315 | application_id: Uuid, |
| 316 | vars: &HashMap<String, String>, |
| 317 | pl: &integration::TxAckEvent, |
| 318 | ) { |
| 319 | tokio::spawn({ |
| 320 | let vars = vars.clone(); |
| 321 | let pl = pl.clone(); |
| 322 | |
| 323 | async move { |
| 324 | if let Err(err) = _txack_event(application_id, &vars, &pl).await { |
| 325 | warn!(application_id = %application_id, error = %err.full(), "Txack event error"); |
| 326 | } |
| 327 | } |
| 328 | }); |
| 329 | } |
| 330 | |
| 331 | async fn _txack_event( |
| 332 | application_id: Uuid, |
no test coverage detected