(pl: integration_pb::TxAckEvent)
| 329 | } |
| 330 | |
| 331 | async fn txack_event(pl: integration_pb::TxAckEvent) { |
| 332 | let integration = INTEGRATION.read().await; |
| 333 | if let Err(e) = integration.as_ref().unwrap().txack_event(&pl).await { |
| 334 | error!(error = %e, "Tx ack event error"); |
| 335 | } |
| 336 | } |
| 337 | |
| 338 | async fn status_event(pl: integration_pb::StatusEvent) { |
| 339 | let integration = INTEGRATION.read().await; |
no test coverage detected