(
&self,
target_role: Role,
pl: &mut XmitDataReqPayload,
async_resp: Option<Receiver<Vec<u8>>>,
)
| 257 | } |
| 258 | |
| 259 | pub async fn xmit_data_req( |
| 260 | &self, |
| 261 | target_role: Role, |
| 262 | pl: &mut XmitDataReqPayload, |
| 263 | async_resp: Option<Receiver<Vec<u8>>>, |
| 264 | ) -> Result<XmitDataAnsPayload> { |
| 265 | pl.base.sender_id.clone_from(&self.config.sender_id); |
| 266 | pl.base.receiver_id.clone_from(&self.config.receiver_id); |
| 267 | pl.base.message_type = MessageType::XmitDataReq; |
| 268 | |
| 269 | let mut ans: XmitDataAnsPayload = Default::default(); |
| 270 | self.request(Some(target_role), &pl, &mut ans, async_resp) |
| 271 | .await?; |
| 272 | Ok(ans) |
| 273 | } |
| 274 | |
| 275 | pub async fn xmit_data_ans(&self, target_role: Role, pl: &XmitDataAnsPayload) -> Result<()> { |
| 276 | self.response_request(Some(target_role), pl).await |
no test coverage detected