(
&self,
target_role: Role,
pl: &mut PRStartReqPayload,
async_resp: Option<Receiver<Vec<u8>>>,
)
| 198 | } |
| 199 | |
| 200 | pub async fn pr_start_req( |
| 201 | &self, |
| 202 | target_role: Role, |
| 203 | pl: &mut PRStartReqPayload, |
| 204 | async_resp: Option<Receiver<Vec<u8>>>, |
| 205 | ) -> Result<PRStartAnsPayload> { |
| 206 | pl.base.sender_id.clone_from(&self.config.sender_id); |
| 207 | pl.base.receiver_id.clone_from(&self.config.receiver_id); |
| 208 | pl.base.message_type = MessageType::PRStartReq; |
| 209 | |
| 210 | let mut ans: PRStartAnsPayload = Default::default(); |
| 211 | self.request(Some(target_role), &pl, &mut ans, async_resp) |
| 212 | .await?; |
| 213 | Ok(ans) |
| 214 | } |
| 215 | |
| 216 | pub async fn pr_start_ans(&self, target_role: Role, pl: &PRStartAnsPayload) -> Result<()> { |
| 217 | self.response_request(Some(target_role), pl).await |
no test coverage detected