(
&self,
receiver_id: Vec<u8>,
pl: &mut JoinReqPayload,
async_resp: Option<Receiver<Vec<u8>>>,
)
| 155 | } |
| 156 | |
| 157 | pub async fn join_req( |
| 158 | &self, |
| 159 | receiver_id: Vec<u8>, |
| 160 | pl: &mut JoinReqPayload, |
| 161 | async_resp: Option<Receiver<Vec<u8>>>, |
| 162 | ) -> Result<JoinAnsPayload> { |
| 163 | pl.base.sender_id.clone_from(&self.config.sender_id); |
| 164 | pl.base.receiver_id = receiver_id; |
| 165 | pl.base.message_type = MessageType::JoinReq; |
| 166 | |
| 167 | let mut ans: JoinAnsPayload = Default::default(); |
| 168 | self.request(None, &pl, &mut ans, async_resp).await?; |
| 169 | Ok(ans) |
| 170 | } |
| 171 | |
| 172 | pub async fn rejoin_req( |
| 173 | &self, |
no test coverage detected