(&self, channel_id: &str, error: String)
| 323 | } |
| 324 | |
| 325 | pub fn fail_pending_relay(&self, channel_id: &str, error: String) -> bool { |
| 326 | let pending = self.pending_relays.lock().unwrap().remove(channel_id); |
| 327 | if let Some(pending) = pending { |
| 328 | let _ = pending.sender.send(Err(Status::unavailable(error))); |
| 329 | true |
| 330 | } else { |
| 331 | false |
| 332 | } |
| 333 | } |
| 334 | |
| 335 | /// Claim a pending relay channel. Called by the `/relay/{channel_id}` HTTP handler |
| 336 | /// when the supervisor's reverse CONNECT arrives. |
no test coverage detected