(&self, pl: &integration_pb::AckEvent)
| 396 | } |
| 397 | |
| 398 | async fn ack_event(&self, pl: &integration_pb::AckEvent) -> Result<()> { |
| 399 | ACK_EVENTS.write().await.push(pl.clone()); |
| 400 | Ok(()) |
| 401 | } |
| 402 | |
| 403 | async fn txack_event(&self, pl: &integration_pb::TxAckEvent) -> Result<()> { |
| 404 | TXACK_EVENTS.write().await.push(pl.clone()); |