(
&self,
_vars: &HashMap<String, String>,
pl: &integration::TxAckEvent,
)
| 131 | } |
| 132 | |
| 133 | async fn txack_event( |
| 134 | &self, |
| 135 | _vars: &HashMap<String, String>, |
| 136 | pl: &integration::TxAckEvent, |
| 137 | ) -> Result<()> { |
| 138 | let b = match self.json { |
| 139 | true => serde_json::to_vec(&pl)?, |
| 140 | false => pl.encode_to_vec(), |
| 141 | }; |
| 142 | |
| 143 | self.post_event("txack", b).await |
| 144 | } |
| 145 | |
| 146 | async fn log_event( |
| 147 | &self, |